net.bluemind.vertx.testhelper

Class FakeNetSocket

java.lang.Object

net.bluemind.vertx.testhelper.FakeNetSocket

All Implemented Interfaces:

io.vertx.core.net.NetSocket, io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>, io.vertx.core.streams.StreamBase, io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

public class FakeNetSocket
extends java.lang.Object
implements io.vertx.core.net.NetSocket

Constructor Summary

Constructors

Constructor and Description
FakeNetSocket(io.vertx.core.Vertx vx, io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer> writeHandler)

Method Summary

Modifier and Type	Method and Description
java.lang.String	applicationLayerProtocol()
io.vertx.core.Future<java.lang.Void>	close()
void	close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> handler)
io.vertx.core.net.NetSocket	closeHandler(io.vertx.core.Handler<java.lang.Void> handler)
io.vertx.core.net.NetSocket	drainHandler(io.vertx.core.Handler<java.lang.Void> handler)
io.vertx.core.Future<java.lang.Void>	end()
void	end(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> handler)
io.vertx.core.net.NetSocket	endHandler(io.vertx.core.Handler<java.lang.Void> endHandler)
io.vertx.core.net.NetSocket	exceptionHandler(io.vertx.core.Handler<java.lang.Throwable> handler)
io.vertx.core.net.NetSocket	fetch(long amount)
io.vertx.core.net.NetSocket	handler(io.vertx.core.Handler<io.vertx.core.buffer.Buffer> handler)
java.lang.String	indicatedServerName()
boolean	isSsl()
io.vertx.core.net.SocketAddress	localAddress()
io.vertx.core.net.NetSocket	pause()
javax.security.cert.X509Certificate[]	peerCertificateChain()
java.util.List<java.security.cert.Certificate>	peerCertificates()
io.vertx.core.net.SocketAddress	remoteAddress()
io.vertx.core.net.NetSocket	resume()
io.vertx.core.Future<java.lang.Void>	sendFile(java.lang.String filename)
io.vertx.core.net.NetSocket	sendFile(java.lang.String filename, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> resultHandler)
io.vertx.core.Future<java.lang.Void>	sendFile(java.lang.String filename, long offset, long length)
io.vertx.core.net.NetSocket	sendFile(java.lang.String filename, long offset, long length, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> resultHandler)
io.vertx.core.net.NetSocket	setWriteQueueMaxSize(int maxSize)
javax.net.ssl.SSLSession	sslSession()
io.vertx.core.Future<java.lang.Void>	upgradeToSsl()
io.vertx.core.net.NetSocket	upgradeToSsl(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> handler)
io.vertx.core.Future<java.lang.Void>	upgradeToSsl(java.lang.String serverName)
io.vertx.core.net.NetSocket	upgradeToSsl(java.lang.String serverName, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> handler)
io.vertx.core.Future<java.lang.Void>	write(io.vertx.core.buffer.Buffer data)
void	write(io.vertx.core.buffer.Buffer message, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> handler)
io.vertx.core.Future<java.lang.Void>	write(java.lang.String str)
void	write(java.lang.String str, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> handler)
io.vertx.core.Future<java.lang.Void>	write(java.lang.String str, java.lang.String enc)
void	write(java.lang.String str, java.lang.String enc, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> handler)
java.lang.String	writeHandlerID()
boolean	writeQueueFull()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.vertx.core.net.NetSocket

sendFile, sendFile

Methods inherited from interface io.vertx.core.streams.ReadStream

pipe, pipeTo, pipeTo

Methods inherited from interface io.vertx.core.streams.WriteStream

end, end

Constructor Detail

FakeNetSocket

public FakeNetSocket(io.vertx.core.Vertx vx,
                     io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer> writeHandler)

Method Detail

endHandler

public io.vertx.core.net.NetSocket endHandler(io.vertx.core.Handler<java.lang.Void> endHandler)

Specified by:

endHandler in interface io.vertx.core.net.NetSocket

Specified by:

endHandler in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

handler

public io.vertx.core.net.NetSocket handler(io.vertx.core.Handler<io.vertx.core.buffer.Buffer> handler)

Specified by:

handler in interface io.vertx.core.net.NetSocket

Specified by:

handler in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

pause

public io.vertx.core.net.NetSocket pause()

Specified by:

pause in interface io.vertx.core.net.NetSocket

Specified by:

pause in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

resume

public io.vertx.core.net.NetSocket resume()

Specified by:

resume in interface io.vertx.core.net.NetSocket

Specified by:

resume in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

exceptionHandler

public io.vertx.core.net.NetSocket exceptionHandler(io.vertx.core.Handler<java.lang.Throwable> handler)

Specified by:

exceptionHandler in interface io.vertx.core.net.NetSocket

Specified by:

exceptionHandler in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

Specified by:

exceptionHandler in interface io.vertx.core.streams.StreamBase

Specified by:

exceptionHandler in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

setWriteQueueMaxSize

public io.vertx.core.net.NetSocket setWriteQueueMaxSize(int maxSize)

Specified by:

setWriteQueueMaxSize in interface io.vertx.core.net.NetSocket

Specified by:

setWriteQueueMaxSize in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

writeQueueFull

public boolean writeQueueFull()

Specified by:

writeQueueFull in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

drainHandler

public io.vertx.core.net.NetSocket drainHandler(io.vertx.core.Handler<java.lang.Void> handler)

Specified by:

drainHandler in interface io.vertx.core.net.NetSocket

Specified by:

drainHandler in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

writeHandlerID

public java.lang.String writeHandlerID()

Specified by:

writeHandlerID in interface io.vertx.core.net.NetSocket

write

public io.vertx.core.Future<java.lang.Void> write(io.vertx.core.buffer.Buffer data)

Specified by:

write in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

write

public io.vertx.core.Future<java.lang.Void> write(java.lang.String str)

Specified by:

write in interface io.vertx.core.net.NetSocket

write

public io.vertx.core.Future<java.lang.Void> write(java.lang.String str,
                                                  java.lang.String enc)

Specified by:

write in interface io.vertx.core.net.NetSocket

sendFile

public io.vertx.core.Future<java.lang.Void> sendFile(java.lang.String filename)

Specified by:

sendFile in interface io.vertx.core.net.NetSocket

sendFile

public io.vertx.core.net.NetSocket sendFile(java.lang.String filename,
                                            io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> resultHandler)

Specified by:

sendFile in interface io.vertx.core.net.NetSocket

remoteAddress

public io.vertx.core.net.SocketAddress remoteAddress()

Specified by:

remoteAddress in interface io.vertx.core.net.NetSocket

localAddress

public io.vertx.core.net.SocketAddress localAddress()

Specified by:

localAddress in interface io.vertx.core.net.NetSocket

close

public io.vertx.core.Future<java.lang.Void> close()

Specified by:

close in interface io.vertx.core.net.NetSocket

closeHandler

public io.vertx.core.net.NetSocket closeHandler(io.vertx.core.Handler<java.lang.Void> handler)

Specified by:

closeHandler in interface io.vertx.core.net.NetSocket

isSsl

public boolean isSsl()

Specified by:

isSsl in interface io.vertx.core.net.NetSocket

fetch

public io.vertx.core.net.NetSocket fetch(long amount)

Specified by:

fetch in interface io.vertx.core.net.NetSocket

Specified by:

fetch in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

write

public void write(java.lang.String str,
                  io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> handler)

Specified by:

write in interface io.vertx.core.net.NetSocket

write

public void write(java.lang.String str,
                  java.lang.String enc,
                  io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> handler)

Specified by:

write in interface io.vertx.core.net.NetSocket

write

public void write(io.vertx.core.buffer.Buffer message,
                  io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> handler)

Specified by:

write in interface io.vertx.core.net.NetSocket

Specified by:

write in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

sendFile

public io.vertx.core.Future<java.lang.Void> sendFile(java.lang.String filename,
                                                     long offset,
                                                     long length)

Specified by:

sendFile in interface io.vertx.core.net.NetSocket

sendFile

public io.vertx.core.net.NetSocket sendFile(java.lang.String filename,
                                            long offset,
                                            long length,
                                            io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> resultHandler)

Specified by:

sendFile in interface io.vertx.core.net.NetSocket

end

public io.vertx.core.Future<java.lang.Void> end()

Specified by:

end in interface io.vertx.core.net.NetSocket

Specified by:

end in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

end

public void end(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> handler)

Specified by:

end in interface io.vertx.core.net.NetSocket

Specified by:

end in interface io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer>

close

public void close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> handler)

Specified by:

close in interface io.vertx.core.net.NetSocket

sslSession

public javax.net.ssl.SSLSession sslSession()

Specified by:

sslSession in interface io.vertx.core.net.NetSocket

peerCertificateChain

public javax.security.cert.X509Certificate[] peerCertificateChain()
                                                           throws javax.net.ssl.SSLPeerUnverifiedException

Specified by:

peerCertificateChain in interface io.vertx.core.net.NetSocket

Throws:

javax.net.ssl.SSLPeerUnverifiedException

indicatedServerName

public java.lang.String indicatedServerName()

Specified by:

indicatedServerName in interface io.vertx.core.net.NetSocket

upgradeToSsl

public io.vertx.core.net.NetSocket upgradeToSsl(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> handler)

Specified by:

upgradeToSsl in interface io.vertx.core.net.NetSocket

upgradeToSsl

public io.vertx.core.Future<java.lang.Void> upgradeToSsl()

Specified by:

upgradeToSsl in interface io.vertx.core.net.NetSocket

upgradeToSsl

public io.vertx.core.net.NetSocket upgradeToSsl(java.lang.String serverName,
                                                io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> handler)

Specified by:

upgradeToSsl in interface io.vertx.core.net.NetSocket

upgradeToSsl

public io.vertx.core.Future<java.lang.Void> upgradeToSsl(java.lang.String serverName)

Specified by:

upgradeToSsl in interface io.vertx.core.net.NetSocket

peerCertificates

public java.util.List<java.security.cert.Certificate> peerCertificates()
                                                                throws javax.net.ssl.SSLPeerUnverifiedException

Specified by:

peerCertificates in interface io.vertx.core.net.NetSocket

Throws:

javax.net.ssl.SSLPeerUnverifiedException

applicationLayerProtocol

public java.lang.String applicationLayerProtocol()

Specified by:

applicationLayerProtocol in interface io.vertx.core.net.NetSocket