ai.z.openapi.service.realtime

Class OkHttpRealtimeClient

java.lang.Object

ai.z.openapi.service.realtime.OkHttpRealtimeClient

All Implemented Interfaces:

Closeable, AutoCloseable

public final class OkHttpRealtimeClient
extends Object
implements Closeable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	OkHttpRealtimeClient.CommunicationProvider
static class	OkHttpRealtimeClient.ConnectivityMonitor
static class	OkHttpRealtimeClient.ConnectivityState

Constructor Summary

Constructors

Constructor and Description
OkHttpRealtimeClient(OkHttpRealtimeClient.CommunicationProvider communicationProvider, Consumer<RealtimeServerEvent> serverEventHandler)
OkHttpRealtimeClient(OkHttpRealtimeClient.CommunicationProvider communicationProvider, Consumer<RealtimeServerEvent> serverEventHandler, okhttp3.OkHttpClient client)
OkHttpRealtimeClient(OkHttpRealtimeClient.CommunicationProvider communicationProvider, Consumer<RealtimeServerEvent> serverEventHandler, okhttp3.OkHttpClient client, boolean closeClientOnClose)

Method Summary

Modifier and Type	Method and Description
void	close()
void	sendMessage(RealtimeClientEvent clientEvent)
void	start()
void	stop()
void	waitForConnection()

Methods inherited from class java.lang.Object

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

Constructor Detail

OkHttpRealtimeClient

public OkHttpRealtimeClient(OkHttpRealtimeClient.CommunicationProvider communicationProvider,
                            Consumer<RealtimeServerEvent> serverEventHandler,
                            okhttp3.OkHttpClient client)

OkHttpRealtimeClient

public OkHttpRealtimeClient(OkHttpRealtimeClient.CommunicationProvider communicationProvider,
                            Consumer<RealtimeServerEvent> serverEventHandler,
                            okhttp3.OkHttpClient client,
                            boolean closeClientOnClose)

OkHttpRealtimeClient

public OkHttpRealtimeClient(OkHttpRealtimeClient.CommunicationProvider communicationProvider,
                            Consumer<RealtimeServerEvent> serverEventHandler)

Method Detail

start

public void start()

stop

public void stop()

waitForConnection

public void waitForConnection()
                       throws InterruptedException

Throws:

InterruptedException

sendMessage

public void sendMessage(RealtimeClientEvent clientEvent)

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException