Functions — github.com/jetlang/remoting

hub / github.com/jetlang/remoting / functions

Functions938 in github.com/jetlang/remoting

⨍ Functions 938◇ Types & classes 201

↓ 3 callersMethodgetContentAsString

(boolean failOnUnsupportedEncoding)

src/main/java/org/jetlang/web/HttpRequest.java:136

↓ 3 callersMethodgetHeartbeatIntervalInMs

()

src/main/java/org/jetlang/remote/client/JetlangClientConfig.java:16

↓ 3 callersMethodgetHeartbeatIntervalInMs

()

src/main/java/org/jetlang/remote/acceptor/JetlangSessionConfig.java:15

↓ 3 callersMethodgetOutputStream

()

src/main/java/org/jetlang/remote/core/ClosableOutputStream.java:13

↓ 3 callersMethodgetPath

()

src/main/java/org/jetlang/web/HttpRequest.java:78

↓ 3 callersMethodgetReadTimeoutInMs

()

src/main/java/org/jetlang/remote/acceptor/JetlangSessionConfig.java:43

↓ 3 callersMethodgetReader

()

src/main/java/org/jetlang/remote/core/Serializer.java:6

↓ 3 callersMethodgetRemoteSocketAddress

()

src/main/java/org/jetlang/remote/core/TcpSocket.java:48

↓ 3 callersMethodgetRequest

()

src/main/java/org/jetlang/web/WebSocketConnection.java:11

↓ 3 callersMethodgetSessionMessageChannel

()

src/main/java/org/jetlang/remote/acceptor/JetlangSession.java:24

↓ 3 callersMethodgetSessionRequestChannel

()

src/main/java/org/jetlang/remote/acceptor/JetlangSession.java:26

↓ 3 callersMethodgetWriter

()

src/main/java/org/jetlang/remote/core/Serializer.java:4

↓ 3 callersMethodhandle

(Fiber dispatchFiber, HttpRequest headers, HttpResponse writer, T sessionState)

src/main/java/org/jetlang/web/HttpHandler.java:12

↓ 3 callersMethodisCurrentCharEol

(ByteBuffer buffer)

src/main/java/org/jetlang/web/HeaderReader.java:197

↓ 3 callersMethodonNotYetAuthenticated

(HttpRequest headers, HttpResponse writer, T sessionState, String name)

src/main/java/org/jetlang/web/AuthFailuresHandler.java:6

↓ 3 callersMethodreceiveMessage

(T message)

src/test/java/org/jetlang/remote/EventAssert.java:60

↓ 3 callersMethodremoveSubscriptions

(ChannelState channel)

src/main/java/org/jetlang/remote/acceptor/NioJetlangSendFiber.java:226

↓ 3 callersMethodrequest

(String reqTopic, Object req, DisposingExecutor executor

src/main/java/org/jetlang/remote/client/JetlangClient.java:37

↓ 3 callersMethodrunIfActive

(Runnable runnable)

src/main/java/org/jetlang/web/WebSocketConnectionImpl.java:158

↓ 3 callersMethodsafeCloseAndLog

(IOException e)

src/main/java/org/jetlang/remote/acceptor/NioJetlangSendFiber.java:123

↓ 3 callersMethodsendBinary

Non-Blocking send of a binary message.

src/main/java/org/jetlang/web/WebSocketConnection.java:41

↓ 3 callersMethodsendSubscription

(String subject, int msgType)

src/main/java/org/jetlang/remote/client/JetlangTcpClient.java:186

↓ 3 callersMethodsendUnauthorizedResponse

(HttpResponse writer, String name)

src/main/java/org/jetlang/web/AuthFailuresHandler.java:10

↓ 3 callersMethodsetMask

(byte b, boolean mask)

src/main/java/org/jetlang/web/WebSocketConnectionImpl.java:109

↓ 3 callersMethodstart

()

src/main/java/org/jetlang/web/WebSocketClient.java:289

↓ 3 callersMethodstop

(NioControls nioControls)

src/main/java/org/jetlang/web/WebSocketClient.java:41

↓ 3 callersMethodstopAndRemove

(ClientTcpSocket client)

src/main/java/org/jetlang/remote/acceptor/JetlangClientHandler.java:112

↓ 3 callersMethodtryClose

()

src/main/java/org/jetlang/remote/acceptor/MessageStreamWriter.java:21

↓ 3 callersMethodwriteBytes

(byte[] bytes)

src/main/java/org/jetlang/remote/acceptor/MessageStreamWriter.java:19

↓ 3 callersMethodwriteData

(String topic, Object req)

src/main/java/org/jetlang/remote/core/SocketMessageStreamWriter.java:82

↓ 3 callersMethodwriteObjectAsBytes

(byte[] buffer, int offset, int length)

src/main/java/org/jetlang/remote/core/ByteMessageWriter.java:9

↓ 2 callersMethodadd

(Channel<T> channel)

src/main/java/org/jetlang/remote/core/CloseableChannel.java:89

↓ 2 callersMethodattemptCloseOnNioFiber

()

src/main/java/org/jetlang/web/NioWriter.java:121

↓ 2 callersMethodbufferAllocate

(int size)

src/main/java/org/jetlang/web/NioReader.java:60

↓ 2 callersMethodclose

(final boolean sendLogoutIfStillConnected)

src/main/java/org/jetlang/remote/client/JetlangTcpClient.java:341

↓ 2 callersMethodcloseAndClear

()

src/main/java/org/jetlang/remote/core/CloseableChannel.java:98

↓ 2 callersMethodcloseIfNeeded

(CloseEvent closeCause)

src/main/java/org/jetlang/remote/client/JetlangTcpClient.java:198

↓ 2 callersMethodconnect

()

src/main/java/org/jetlang/remote/client/SocketConnector.java:63

↓ 2 callersMethodcreate

()

src/test/java/org/jetlang/remote/CallbackList.java:17

↓ 2 callersMethodcreate

(NioFiber readFiber)

src/main/java/org/jetlang/web/WebServerConfigBuilder.java:146

↓ 2 callersMethodcreateArray

(String topic, Object msg)

src/main/java/org/jetlang/remote/acceptor/BufferedSerializer.java:27

↓ 2 callersMethodcreateBuffered

()

src/main/java/org/jetlang/remote/acceptor/SerializerAdapter.java:23

↓ 2 callersMethodcreateFor

(SocketChannel channel, NioFiber fiber)

src/main/java/org/jetlang/web/IoBufferPool.java:17

↓ 2 callersMethodcreateForSocket

(Socket socket)

src/main/java/org/jetlang/remote/core/SerializerFactory.java:14

↓ 2 callersMethoddecode

(String substring)

src/main/java/org/jetlang/web/KeyValueList.java:115

↓ 2 callersMethoddisconnect

Attempts to disconnect the client.

src/main/java/org/jetlang/remote/acceptor/JetlangSession.java:35

↓ 2 callersMethoddispatchHttpRequest

(HttpRequest headers)

src/main/java/org/jetlang/web/HeaderReader.java:85

↓ 2 callersMethoddispose

()

src/main/java/org/jetlang/web/WebSocketConnectionImpl.java:218

↓ 2 callersMethoddoSend

(ByteBuffer bb)

src/main/java/org/jetlang/web/NioWriter.java:60

↓ 2 callersMethodequalsKey

(String param, String name)

src/main/java/org/jetlang/web/KeyValueList.java:86

↓ 2 callersMethodexecEvent

(Runnable event)

src/main/java/org/jetlang/remote/core/JetlangRemotingProtocol.java:57

↓ 2 callersMethodflush

()

src/main/java/org/jetlang/remote/acceptor/NioJetlangSendFiber.java:322

↓ 2 callersMethodforEach

(Consumer<? super Entry> action)

src/main/java/org/jetlang/web/KeyValueList.java:51

↓ 2 callersMethodgetAll

(String param)

src/main/java/org/jetlang/web/KeyValueList.java:76

↓ 2 callersMethodgetCloseChannel

()

src/main/java/org/jetlang/remote/client/JetlangTcpClient.java:450

↓ 2 callersMethodgetConnectChannel

()

src/main/java/org/jetlang/remote/client/JetlangTcpClient.java:458

↓ 2 callersMethodgetConnectChannel

()

src/main/java/org/jetlang/remote/client/JetlangClient.java:19

↓ 2 callersMethodgetHeartbeatChannel

()

src/main/java/org/jetlang/remote/acceptor/JetlangSession.java:22

↓ 2 callersMethodgetInputStream

()

src/main/java/org/jetlang/remote/core/TcpSocket.java:56

↓ 2 callersMethodgetLogoutChannel

()

src/main/java/org/jetlang/remote/acceptor/JetlangSession.java:20

↓ 2 callersMethodgetReceiveBufferSize

()

src/main/java/org/jetlang/remote/acceptor/JetlangSessionConfig.java:27

↓ 2 callersMethodgetSendBufferSize

()

src/main/java/org/jetlang/remote/acceptor/JetlangSessionConfig.java:31

↓ 2 callersMethodgetSocket

()

src/main/java/org/jetlang/remote/acceptor/ClientTcpSocket.java:19

↓ 2 callersMethodgetTotalBufferedInBytes

()

src/main/java/org/jetlang/web/SendResult.java:49

↓ 2 callersMethodhandleAuthorization

(HttpRequest headers, HttpResponse writer, T sessionState)

src/main/java/org/jetlang/web/BasicAuthSecurity.java:52

↓ 2 callersMethodhandleConnection

(NioControls nioControls)

src/main/java/org/jetlang/web/WebSocketClient.java:215

↓ 2 callersMethodisClosed

()

src/main/java/org/jetlang/remote/core/CloseableChannel.java:65

↓ 2 callersMethodminRequiredBytes

()

src/main/java/org/jetlang/web/NioReader.java:78

↓ 2 callersMethodonAccept

(NioFiber fiber, NioControls controls, SelectionKey key, SocketChannel channel)

src/main/java/org/jetlang/remote/acceptor/NioAcceptorHandler.java:27

↓ 2 callersMethodonBinaryMessage

(WebSocketConnection connection, T state, byte[] result, int size)

src/main/java/org/jetlang/web/WebSocketHandler.java:17

↓ 2 callersMethodonMessage

(WebSocketConnection connection, T state, String msg)

src/main/java/org/jetlang/web/WebSocketHandler.java:9

↓ 2 callersMethodonOpen

(WebSocketConnection connection, HttpRequest headers, S sessionState)

src/main/java/org/jetlang/web/WebSocketHandler.java:7

↓ 2 callersMethodonPing

(WebSocketConnection connection, T state, byte[] result, int size, StringDecoder charset)

src/main/java/org/jetlang/web/WebSocketHandler.java:19

↓ 2 callersMethodonPong

(WebSocketConnection connection, T state, byte[] result, int size)

src/main/java/org/jetlang/web/WebSocketHandler.java:23

↓ 2 callersMethodonReadTimeout

(ReadTimeoutEvent readTimeoutEvent)

src/main/java/org/jetlang/remote/acceptor/JetlangMessageHandler.java:9

↓ 2 callersMethodonSubscriptionRequest

(String val)

src/main/java/org/jetlang/remote/core/JetlangRemotingProtocol.java:101

↓ 2 callersMethodonUnknownException

(Throwable processingException, SocketChannel channel)

src/main/java/org/jetlang/web/WebSocketHandler.java:27

↓ 2 callersMethodonUnknownMessage

(int read)

src/main/java/org/jetlang/remote/acceptor/JetlangNioSession.java:18

↓ 2 callersMethodonUnsubscribeRequest

(String val)

src/main/java/org/jetlang/remote/core/JetlangRemotingProtocol.java:105

↓ 2 callersMethodparseUrlEncoded

(String query, boolean caseSensitive)

src/main/java/org/jetlang/web/KeyValueList.java:98

↓ 2 callersMethodpasses

(Fiber dispatchFiber, HttpRequest headers, HttpResponse writer, T sessionState)

src/main/java/org/jetlang/web/HttpSecurity.java:6

↓ 2 callersMethodpathEq

(String s)

src/main/java/org/jetlang/web/PathMatcher.java:7

↓ 2 callersMethodpublish

(String topic, T msg)

src/main/java/org/jetlang/remote/client/JetlangTcpClient.java:466

↓ 2 callersMethodreadFromStream

()

src/main/java/org/jetlang/remote/core/JetlangRemotingInputStream.java:21

↓ 2 callersMethodreadObject

(String fromTopic, byte[] buffer, int offset, int length)

src/main/java/org/jetlang/remote/core/ObjectByteReader.java:11

↓ 2 callersMethodreconnectOnClose

(CountDownLatch latch)

src/main/java/org/jetlang/web/WebSocketClient.java:165

↓ 2 callersMethodregister

(Disposable disposable)

src/main/java/org/jetlang/web/WebSocketConnectionImpl.java:171

↓ 2 callersMethodresize

(int i)

src/main/java/org/jetlang/remote/core/ByteArrayBuffer.java:25

↓ 2 callersMethodresizeBuffer

(int requiredBytes)

src/main/java/org/jetlang/remote/core/JetlangRemotingProtocol.java:89

↓ 2 callersMethodsend

(ByteBuffer fullResponse)

src/main/java/org/jetlang/web/HttpResponse.java:54

↓ 2 callersMethodsendClose

()

src/main/java/org/jetlang/web/WebSocketConnectionImpl.java:137

↓ 2 callersMethodsendText

Non-Blocking send of a text message.

src/main/java/org/jetlang/web/WebSocketConnection.java:26

↓ 2 callersMethodsetReceiveBufferSize

(int receiveBufferSize)

src/main/java/org/jetlang/remote/client/SocketConnector.java:51

↓ 2 callersMethodsetRequestUri

(URI requestUri)

src/main/java/org/jetlang/web/HttpRequest.java:48

↓ 2 callersMethodsetSendBufferSize

(int sendBufferSize)

src/main/java/org/jetlang/remote/client/SocketConnector.java:59

↓ 2 callersMethodsetTcpNoDelay

(boolean tcpNoDelay)

src/main/java/org/jetlang/remote/acceptor/JetlangSessionConfig.java:23

↓ 2 callersMethodstart

()

src/main/java/org/jetlang/remote/client/JetlangTcpClient.java:322

↓ 2 callersMethodstart

()

src/main/java/org/jetlang/web/WebSocketReader.java:26

↓ 2 callersMethodstart

()

src/main/java/org/jetlang/web/WebAcceptor.java:27

↓ 2 callersMethodstop

(NioControls nioControls)

src/main/java/org/jetlang/web/WebSocketClient.java:284

← previous next →101–200 of 938, ranked by callers