Package io.getstream.core.faye.client

Class FayeClient

java.lang.Object

okhttp3.WebSocketListener

io.getstream.core.faye.client.FayeClient

public class FayeClient
extends okhttp3.WebSocketListener

Constructor Summary

Constructors

Constructor	Description
FayeClient(URL baseURL)

Method Summary

Modifier and Type	Method	Description
void	connect()
CompletableFuture<Void>	disconnect()
void	handshake()
void	onClosed(okhttp3.WebSocket webSocket, int code, String reason)
void	onFailure(okhttp3.WebSocket webSocket, Throwable t, okhttp3.Response response)
void	onMessage(okhttp3.WebSocket webSocket, String text)
CompletableFuture<Void>	publish(String channel, Map<String,Object> data)
void	setMessageTransformer(MessageTransformer messageTransformer)
void	setStateChangeListener(StateChangeListener stateChangeListener)
CompletableFuture<ChannelSubscription>	subscribe(String channel, ChannelDataCallback callback)
CompletableFuture<ChannelSubscription>	subscribe(String channel, ChannelDataCallback callback, SubscriptionCancelledCallback onCancelled)
void	unsubscribe(String channel, ChannelSubscription channelSubscription)

Methods inherited from class okhttp3.WebSocketListener

onClosing, onMessage, onOpen

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

FayeClient

public FayeClient(URL baseURL)

Method Details

setMessageTransformer

public void setMessageTransformer(MessageTransformer messageTransformer)

setStateChangeListener

public void setStateChangeListener(StateChangeListener stateChangeListener)

onMessage

public void onMessage(okhttp3.WebSocket webSocket,
 String text)

Overrides:

onMessage in class okhttp3.WebSocketListener

onFailure

public void onFailure(okhttp3.WebSocket webSocket,
 Throwable t,
 okhttp3.Response response)

Overrides:

onFailure in class okhttp3.WebSocketListener

onClosed

public void onClosed(okhttp3.WebSocket webSocket,
 int code,
 String reason)

Overrides:

onClosed in class okhttp3.WebSocketListener

handshake

public void handshake()

connect

public void connect()

disconnect

public CompletableFuture<Void> disconnect()

subscribe

public CompletableFuture<ChannelSubscription> subscribe(String channel,
 ChannelDataCallback callback)

subscribe

public CompletableFuture<ChannelSubscription> subscribe(String channel,
 ChannelDataCallback callback,
 SubscriptionCancelledCallback onCancelled)

unsubscribe

public void unsubscribe(String channel,
 ChannelSubscription channelSubscription)

publish

public CompletableFuture<Void> publish(String channel,
 Map<String,Object> data)