package async_websocket
Module WebsocketSource
Source
val create :
?opcode:[ `Text | `Binary ] ->
role:Websocket_role.t ->
Async.Reader.t ->
Async.Writer.t ->
tSource
val close_finished :
t ->
(Connection_close_reason.t * string * Core.Info.t option) Async.Deferred.t