@@ -62,7 +62,7 @@ public void reset() {
62
62
@ Override
63
63
public void listWorkflows (
64
64
ListWorkflowsRequest request , StreamObserver <ListWorkflowsResponse > responseObserver ) {
65
- Object response = responses .remove ();
65
+ Object response = responses .poll ();
66
66
if (response instanceof ListWorkflowsResponse ) {
67
67
requests .add (request );
68
68
responseObserver .onNext (((ListWorkflowsResponse ) response ));
@@ -74,15 +74,15 @@ public void listWorkflows(
74
74
new IllegalArgumentException (
75
75
String .format (
76
76
"Unrecognized response type %s for method ListWorkflows, expected %s or %s" ,
77
- response .getClass ().getName (),
77
+ response == null ? "null" : response .getClass ().getName (),
78
78
ListWorkflowsResponse .class .getName (),
79
79
Exception .class .getName ())));
80
80
}
81
81
}
82
82
83
83
@ Override
84
84
public void getWorkflow (GetWorkflowRequest request , StreamObserver <Workflow > responseObserver ) {
85
- Object response = responses .remove ();
85
+ Object response = responses .poll ();
86
86
if (response instanceof Workflow ) {
87
87
requests .add (request );
88
88
responseObserver .onNext (((Workflow ) response ));
@@ -94,7 +94,7 @@ public void getWorkflow(GetWorkflowRequest request, StreamObserver<Workflow> res
94
94
new IllegalArgumentException (
95
95
String .format (
96
96
"Unrecognized response type %s for method GetWorkflow, expected %s or %s" ,
97
- response .getClass ().getName (),
97
+ response == null ? "null" : response .getClass ().getName (),
98
98
Workflow .class .getName (),
99
99
Exception .class .getName ())));
100
100
}
@@ -103,7 +103,7 @@ public void getWorkflow(GetWorkflowRequest request, StreamObserver<Workflow> res
103
103
@ Override
104
104
public void createWorkflow (
105
105
CreateWorkflowRequest request , StreamObserver <Operation > responseObserver ) {
106
- Object response = responses .remove ();
106
+ Object response = responses .poll ();
107
107
if (response instanceof Operation ) {
108
108
requests .add (request );
109
109
responseObserver .onNext (((Operation ) response ));
@@ -115,7 +115,7 @@ public void createWorkflow(
115
115
new IllegalArgumentException (
116
116
String .format (
117
117
"Unrecognized response type %s for method CreateWorkflow, expected %s or %s" ,
118
- response .getClass ().getName (),
118
+ response == null ? "null" : response .getClass ().getName (),
119
119
Operation .class .getName (),
120
120
Exception .class .getName ())));
121
121
}
@@ -124,7 +124,7 @@ public void createWorkflow(
124
124
@ Override
125
125
public void deleteWorkflow (
126
126
DeleteWorkflowRequest request , StreamObserver <Operation > responseObserver ) {
127
- Object response = responses .remove ();
127
+ Object response = responses .poll ();
128
128
if (response instanceof Operation ) {
129
129
requests .add (request );
130
130
responseObserver .onNext (((Operation ) response ));
@@ -136,7 +136,7 @@ public void deleteWorkflow(
136
136
new IllegalArgumentException (
137
137
String .format (
138
138
"Unrecognized response type %s for method DeleteWorkflow, expected %s or %s" ,
139
- response .getClass ().getName (),
139
+ response == null ? "null" : response .getClass ().getName (),
140
140
Operation .class .getName (),
141
141
Exception .class .getName ())));
142
142
}
@@ -145,7 +145,7 @@ public void deleteWorkflow(
145
145
@ Override
146
146
public void updateWorkflow (
147
147
UpdateWorkflowRequest request , StreamObserver <Operation > responseObserver ) {
148
- Object response = responses .remove ();
148
+ Object response = responses .poll ();
149
149
if (response instanceof Operation ) {
150
150
requests .add (request );
151
151
responseObserver .onNext (((Operation ) response ));
@@ -157,7 +157,7 @@ public void updateWorkflow(
157
157
new IllegalArgumentException (
158
158
String .format (
159
159
"Unrecognized response type %s for method UpdateWorkflow, expected %s or %s" ,
160
- response .getClass ().getName (),
160
+ response == null ? "null" : response .getClass ().getName (),
161
161
Operation .class .getName (),
162
162
Exception .class .getName ())));
163
163
}
0 commit comments