com.aliyun.openservices.iot.api.util

Class StreamUtil

java.lang.Object

com.aliyun.openservices.iot.api.util.StreamUtil

public class StreamUtil
extends Object

Author:

brhao

Date:

16/05/2018

Field Summary

Fields

Modifier and Type	Field and Description
static String	DATA_STREAM_ID
static String	PATH_STREAM_CLOSE
static String	PATH_STREAM_CLOSE_FROM_RECEIVER
static String	PATH_STREAM_OPEN
static String	PATH_STREAM_REGISTER
static String	PATH_STREAM_SEND
static String	PATH_STREAM_UNREGISTER

Constructor Summary

Constructors

Constructor and Description
StreamUtil()

Method Summary

Modifier and Type	Method and Description
static void	checkServiceName(String serviceName)
static Optional<StreamServiceContext>	getDataStreamContext(List<Connection> connections, String dataStreamId)
static String	getDataStreamId(io.netty.handler.codec.http2.Http2Headers headers)
static Map<String,StreamServiceContext>	getDataStreamMaps(Connection connection)
static void	putDataStreamContext(Connection connection, String dataStreamId, StreamServiceContext context)
static void	removeDataStreamContext(Connection connection, String streamId)
static void	setupConnection(Connection connection, Http2StreamListener http2StreamListener)

Methods inherited from class java.lang.Object

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

Field Detail

PATH_STREAM_REGISTER

public static final String PATH_STREAM_REGISTER

See Also:

Constant Field Values

PATH_STREAM_UNREGISTER

public static final String PATH_STREAM_UNREGISTER

See Also:

Constant Field Values

PATH_STREAM_OPEN

public static final String PATH_STREAM_OPEN

See Also:

Constant Field Values

PATH_STREAM_CLOSE

public static final String PATH_STREAM_CLOSE

See Also:

Constant Field Values

PATH_STREAM_SEND

public static final String PATH_STREAM_SEND

See Also:

Constant Field Values

PATH_STREAM_CLOSE_FROM_RECEIVER

public static final String PATH_STREAM_CLOSE_FROM_RECEIVER

See Also:

Constant Field Values

DATA_STREAM_ID

public static final String DATA_STREAM_ID

See Also:

Constant Field Values

Constructor Detail

StreamUtil

public StreamUtil()

Method Detail

setupConnection

public static void setupConnection(Connection connection,
                                   Http2StreamListener http2StreamListener)

getDataStreamMaps

public static Map<String,StreamServiceContext> getDataStreamMaps(Connection connection)

getDataStreamContext

public static Optional<StreamServiceContext> getDataStreamContext(List<Connection> connections,
                                                                  String dataStreamId)

putDataStreamContext

public static void putDataStreamContext(Connection connection,
                                        String dataStreamId,
                                        StreamServiceContext context)

removeDataStreamContext

public static void removeDataStreamContext(Connection connection,
                                           String streamId)

getDataStreamId

public static String getDataStreamId(io.netty.handler.codec.http2.Http2Headers headers)

checkServiceName

public static void checkServiceName(String serviceName)