Skip to content

Commit 57673e5

Browse files
committed
clean up deadcode
1 parent 7e45c62 commit 57673e5

File tree

4 files changed

+3
-321
lines changed

4 files changed

+3
-321
lines changed

v2/pkg/engine/datasource/graphql_datasource/graphql_subscription_client.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -221,9 +221,9 @@ func convertToClientOptions(options GraphQLSubscriptionOptions) (common.Options,
221221
// mapWSSubprotocol maps the string subprotocol to the common.WSSubprotocol type.
222222
func mapWSSubprotocol(proto string) common.WSSubprotocol {
223223
switch proto {
224-
case ProtocolGraphQLWS:
224+
case "graphql-ws":
225225
return common.SubprotocolGraphQLWS
226-
case ProtocolGraphQLTWS:
226+
case "graphql-transport-ws":
227227
return common.SubprotocolGraphQLTransportWS
228228
default:
229229
return common.SubprotocolAuto

v2/pkg/engine/datasource/graphql_datasource/graphql_ws_proto_types.go

Lines changed: 0 additions & 47 deletions
This file was deleted.

v2/pkg/engine/datasource/graphql_datasource/subscriptionclient/cmd/demo/main.go

Lines changed: 0 additions & 271 deletions
This file was deleted.

v2/pkg/engine/datasource/graphql_datasource/subscriptionclient/transport/sse_conn.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ func newSSEConnection(resp *http.Response) *SSEConnection {
3333
}
3434
}
3535

36-
// readLoop reads SSE events from the response body and sends them to the channel.
36+
// ReadLoop reads SSE events from the response body and sends them to the channel.
3737
func (c *SSEConnection) ReadLoop() {
3838
defer c.cleanup()
3939

0 commit comments

Comments
 (0)