TransportWSImp

fmgp.did.framework.TransportWSImp
See theTransportWSImp companion object
class TransportWSImp[MSG](outboundBuf: Queue[MSG], inboundBuf: Hub[MSG], val ws: Websocket[Throwable]) extends TransportWS[Any, MSG]

this API is still a WIP

The Auto reconnect feature was remove.

Attributes

Companion
object
Graph
Supertypes
trait TransportWS[Any, MSG]
trait Transport[Any, MSG, MSG]
class Object
trait Matchable
class Any

Members list

Value members

Concrete methods

override def inbound: ZStream[Any, InErr, MSG]

Reciving from the other side. Income Messages

Reciving from the other side. Income Messages

Attributes

Definition Classes
override def outbound: ZSink[Any, OutErr, MSG, Nothing, Unit]

Send to the other side. Out going Messages

Send to the other side. Out going Messages

Attributes

Definition Classes

Describe properties about the Flow (direction) of data for this transport

Describe properties about the Flow (direction) of data for this transport

Attributes

Describe properties about the Type connection in this transport

Describe properties about the Type connection in this transport

Attributes

Inherited methods

override def id: TransportID

Attributes

Definition Classes
Inherited from:
TransportWS
def provide(env: ZEnvironment[Any]): Transport[Any, MSG, MSG]

Attributes

Inherited from:
Transport
def send(message: MSG): ZIO[Any, Nothing, Unit]

Attributes

Inherited from:
Transport

Concrete fields