JsonTupleSpace

io.github.cakelier.tuples.space.client.JsonTupleSpace$
See theJsonTupleSpace companion trait

Companion object to the JsonTupleSpace trait, containing its factory method.

Attributes

Companion
trait
Graph
Supertypes
class Object
trait Matchable
class Any
Self type

Members list

Value members

Concrete methods

def apply(uri: String, bufferSize: Int, exitOnClose: Boolean)(using system: ActorSystem): Future[JsonTupleSpace]

Factory method for creating a new JsonTupleSpace client. It needs to be specified the URI of the host on which the server is hosted and the client must connect to. The format of the URI should be the URL one and the protocol for connection is the "websocket" one. Another optional parameter that can be specified is the size of the message buffer, which will be used for buffering messages while the connection is still not established or while the connection is interrupted and the client is trying to reconnect. As a "using" parameter an ActorSystem can be given if the default created one is not apt, because the implementation will use an "Akka HTTP Client" under the hood which uses actors for handling requests and responses. This method returns a Future signalling the completion of the connection operation to the server.

Factory method for creating a new JsonTupleSpace client. It needs to be specified the URI of the host on which the server is hosted and the client must connect to. The format of the URI should be the URL one and the protocol for connection is the "websocket" one. Another optional parameter that can be specified is the size of the message buffer, which will be used for buffering messages while the connection is still not established or while the connection is interrupted and the client is trying to reconnect. As a "using" parameter an ActorSystem can be given if the default created one is not apt, because the implementation will use an "Akka HTTP Client" under the hood which uses actors for handling requests and responses. This method returns a Future signalling the completion of the connection operation to the server.

Value parameters

bufferSize

the size of the buffer used for keeping messages while the client is not connected to the server

system

the ActorSystem to be used for instantiating the "Akka HTTP Client" used under the hood

uri

the URI of the server to which this client should connect to

Attributes

Returns

a Future which its completion signals the established connection to the server