Package com.javiergs.cortex4j

Class CortexSession

java.lang.Object

com.javiergs.cortex4j.CortexSession

All Implemented Interfaces:

AutoCloseable

public final class CortexSession
extends Object
implements AutoCloseable

High-level authenticated Cortex session with per-stream observers. The first available headset is selected; explicit headset selection can be added later without changing the underlying CortexRpcClient API.

Method Summary

Modifier and Type	Method	Description
void	addListener(String stream, CortexListener listener)
void	close()
static CortexSession	connect()
static CortexSession	connect(CortexCredentials credentials)
static CompletableFuture<CortexSession>	connectAsync(CortexCredentials credentials)
static CompletableFuture<CortexSession>	connectAsync(URI endpoint, CortexCredentials credentials)
ConnectionSecurity	getConnectionSecurity()
String	getHeadsetId()	Headset selected when this session was created.
List<String>	getSensorLabels()	Sensor labels reported by Cortex for the active headset.
void	removeListener(String stream, CortexListener listener)
void	subscribe(String... streams)
void	unsubscribe(String... streams)

Methods inherited from class java.lang.Object

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

Method Details

connect

public static CortexSession connect()

connect

public static CortexSession connect(CortexCredentials credentials)

connectAsync

public static CompletableFuture<CortexSession> connectAsync(CortexCredentials credentials)

connectAsync

public static CompletableFuture<CortexSession> connectAsync(URI endpoint,
 CortexCredentials credentials)

getHeadsetId

public String getHeadsetId()

Headset selected when this session was created.

getSensorLabels

public List<String> getSensorLabels()

Sensor labels reported by Cortex for the active headset.

addListener

public void addListener(String stream,
 CortexListener listener)

removeListener

public void removeListener(String stream,
 CortexListener listener)

subscribe

public void subscribe(String... streams)

unsubscribe

public void unsubscribe(String... streams)

getConnectionSecurity

public ConnectionSecurity getConnectionSecurity()

close

public void close()

Specified by:

close in interface AutoCloseable