diff --git a/internal_packages/worker-sync/lib/nylas-long-connection.coffee b/internal_packages/worker-sync/lib/nylas-long-connection.coffee index 63cb49f11..8c20c7603 100644 --- a/internal_packages/worker-sync/lib/nylas-long-connection.coffee +++ b/internal_packages/worker-sync/lib/nylas-long-connection.coffee @@ -135,7 +135,7 @@ class NylasLongConnection socket.on 'connect', => @setStatus(NylasLongConnection.Status.Connected) @closeIfDataStops() - @_req.write("1") + @_req.end() close: -> diff --git a/src/flux/nylas-long-connection.es6 b/src/flux/nylas-long-connection.es6 index 7aa2ebb14..9f252c351 100644 --- a/src/flux/nylas-long-connection.es6 +++ b/src/flux/nylas-long-connection.es6 @@ -151,7 +151,7 @@ class NylasLongConnection { this.closeIfDataStops() }) }) - this._req.write("1") + this._req.end() return this }