Class PublishKt
-
- All Implemented Interfaces:
public final class PublishKt
-
-
Method Summary
Modifier and Type Method Description final static Longpublish(RedisConnection $self, String channel, String message)final static Longpublish(RedisConnection $self, String channel, ByteArray message)final static Longpublish(RedisConnectionPool $self, String channel, String message)final static Longpublish(RedisConnectionPool $self, String channel, ByteArray message)final static Unitpublish(RedisPipelineBuilder $self, String channel, String message, Function1<Long, Unit> onResult)final static Unitpublish(RedisPipelineBuilder $self, String channel, ByteArray message, Function1<Long, Unit> onResult)final static LongpublishStreaming(RedisConnection $self, String channel, StreamWithLength message)final static LongpublishStreaming(RedisConnectionPool $self, String channel, StreamWithLength message)final static UnitpublishStreaming(RedisPipelineBuilder $self, String channel, StreamWithLength message, Function1<Long, Unit> onResult)-
-
Method Detail
-
publish
final static Long publish(RedisConnection $self, String channel, String message)
-
publish
final static Long publish(RedisConnection $self, String channel, ByteArray message)
-
publish
final static Long publish(RedisConnectionPool $self, String channel, String message)
-
publish
final static Long publish(RedisConnectionPool $self, String channel, ByteArray message)
-
publish
final static Unit publish(RedisPipelineBuilder $self, String channel, String message, Function1<Long, Unit> onResult)
-
publish
final static Unit publish(RedisPipelineBuilder $self, String channel, ByteArray message, Function1<Long, Unit> onResult)
-
publishStreaming
final static Long publishStreaming(RedisConnection $self, String channel, StreamWithLength message)
-
publishStreaming
final static Long publishStreaming(RedisConnectionPool $self, String channel, StreamWithLength message)
-
publishStreaming
final static Unit publishStreaming(RedisPipelineBuilder $self, String channel, StreamWithLength message, Function1<Long, Unit> onResult)
-
-
-
-