class RedisConnection extends ReadStream[Response]
A simple Redis client.
- Alphabetic
- By Inheritance
- RedisConnection
- ReadStream
- StreamBase
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
- new RedisConnection(_asJava: AnyRef)
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
asJava: AnyRef
- Definition Classes
- RedisConnection → ReadStream → StreamBase
-
def
batch(commands: Buffer[Request], onSend: Handler[AsyncResult[Buffer[Option[Response]]]]): RedisConnection
Sends a list of commands in a single IO operation, this prevents any inter twinning to happen from other client users.
Sends a list of commands in a single IO operation, this prevents any inter twinning to happen from other client users. * @param commands list of command to send
- onSend
the asynchronous result handler.
- returns
fluent self.
-
def
batchFuture(commands: Buffer[Request]): Future[Buffer[Option[Response]]]
Like batch but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
def
close(): Unit
Closes the connection or returns to the pool.
-
def
endHandler(endHandler: Handler[Unit]): RedisConnection
- Definition Classes
- RedisConnection → ReadStream
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
exceptionHandler(handler: Handler[Throwable]): RedisConnection
- returns
a reference to this, so the API can be used fluently
- Definition Classes
- RedisConnection → ReadStream → StreamBase
-
def
fetch(amount: Long): RedisConnection
- Definition Classes
- RedisConnection → ReadStream
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
handler(handler: Handler[Response]): RedisConnection
- Definition Classes
- RedisConnection → ReadStream
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
def
pause(): RedisConnection
- Definition Classes
- RedisConnection → ReadStream
-
def
pendingQueueFull(): Boolean
Flag to notify if the pending message queue (commands in transit) is full.
Flag to notify if the pending message queue (commands in transit) is full.
When the pending message queue is full and a new send command is issued it will result in a exception to be thrown. Checking this flag before sending can allow the application to wait before sending the next message. * @return true is queue is full.
-
def
pipe(): Pipe[Response]
Pause this stream and return a io.vertx.scala.core.streams.Pipe to transfer the elements of this stream to a destination io.vertx.scala.core.streams.WriteStream.
Pause this stream and return a io.vertx.scala.core.streams.Pipe to transfer the elements of this stream to a destination io.vertx.scala.core.streams.WriteStream.
The stream will be resumed when the pipe will be wired to a
WriteStream
. * @return a pipe- Definition Classes
- RedisConnection → ReadStream
-
def
pipeTo(dst: WriteStream[Response], handler: Handler[AsyncResult[Unit]]): Unit
Pipe this
ReadStream
to theWriteStream
.Pipe this
ReadStream
to theWriteStream
.Elements emitted by this stream will be written to the write stream until this stream ends or fails.
Once this stream has ended or failed, the write stream will be ended and the
handler
will be called with the result. * @param dst the destination write stream- Definition Classes
- RedisConnection → ReadStream
-
def
pipeTo(dst: WriteStream[Response]): Unit
Like io.vertx.scala.core.streams.ReadStream#pipeTo but with no completion handler.
Like io.vertx.scala.core.streams.ReadStream#pipeTo but with no completion handler.
- Definition Classes
- RedisConnection → ReadStream
-
def
pipeToFuture(dst: WriteStream[Response]): Future[Unit]
Like pipeTo but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
Like pipeTo but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
- Definition Classes
- RedisConnection → ReadStream
-
def
resume(): RedisConnection
- Definition Classes
- RedisConnection → ReadStream
-
def
send(command: Request, onSend: Handler[AsyncResult[Option[Response]]]): RedisConnection
Send the given command to the redis server or cluster.
Send the given command to the redis server or cluster. * @param command the command to send
- onSend
the asynchronous result handler.
- returns
fluent self.
-
def
sendFuture(command: Request): Future[Option[Response]]
Like send but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )