diff --git a/packages/graphql/lib/src/links/websocket_link/websocket_client.dart b/packages/graphql/lib/src/links/websocket_link/websocket_client.dart index 1809cd65..52d754c2 100644 --- a/packages/graphql/lib/src/links/websocket_link/websocket_client.dart +++ b/packages/graphql/lib/src/links/websocket_link/websocket_client.dart @@ -576,15 +576,17 @@ class SocketClient { .listen((message) => response.addError(message)); if (!_subscriptionInitializers[id]!.hasBeenTriggered) { - GraphQLSocketMessage operation = StartOperation( - id, - serialize(payload), - ); + GraphQLSocketMessage operation; if (protocol == GraphQLProtocol.graphqlTransportWs) { operation = SubscribeOperation( id, serialize(payload), ); + } else { + operation = StartOperation( + id, + serialize(payload), + ); } _write(operation); _subscriptionInitializers[id]!.hasBeenTriggered = true;