Functions — github.com/jetlang/remoting

hub / github.com/jetlang/remoting / functions

Functions938 in github.com/jetlang/remoting

⨍ Functions 938◇ Types & classes 201

↓ 46 callersMethodexecute

(Runnable command)

src/main/java/org/jetlang/web/WebFiberConnection.java:74

↓ 45 callersMethodsubscribe

(String subject, Subscribable<T> callback)

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

↓ 42 callersMethodget

(String key)

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

↓ 33 callersMethodassertEvent

()

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

↓ 29 callersMethodstart

(SessionDispatcherFactory.SessionDispatcher<T> dispatcher, HttpRequest headers, HttpResponse response, HeaderR

src/main/java/org/jetlang/web/Handler.java:4

↓ 19 callersMethodstart

()

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

↓ 18 callersMethodappend

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

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

↓ 17 callersMethoddispose

()

src/main/java/org/jetlang/web/WebFiberConnection.java:94

↓ 16 callersMethodadd

(String name, String value)

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

↓ 16 callersMethodawait

(int time, TimeUnit unit)

src/main/java/org/jetlang/remote/client/LogoutResult.java:24

↓ 16 callersMethodpublish

publish raw bytes. The bytes should be correctly formatted with the topic included. The bytes will be published asynchronously, so the byte array shou

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

↓ 16 callersMethodwrap

(NewFiberSessionHandler newFiberSessionHandler)

src/test/java/org/jetlang/remote/IntegrationBase.java:92

↓ 15 callersMethodclose

()

src/main/java/org/jetlang/remote/acceptor/Acceptor.java:39

↓ 15 callersMethodsize

()

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

↓ 14 callersMethodcreateClient

()

src/test/java/org/jetlang/remote/IntegrationBase.java:477

↓ 14 callersMethodonException

(Exception e)

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

↓ 13 callersMethodset

(ChannelState channel)

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

↓ 13 callersMethodstop

()

src/main/java/org/jetlang/remote/acceptor/Acceptor.java:60

↓ 12 callersMethodcreateAcceptor

(NewSessionHandler newSession)

src/test/java/org/jetlang/remote/IntegrationBase.java:481

↓ 12 callersMethodpublish

(String topic, T msg)

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

↓ 12 callersMethodremove

(CloseableChannel<?> toRemove)

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

↓ 12 callersMethodrun

()

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

↓ 11 callersMethodappendIntAsByte

(int msgType)

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

↓ 10 callersMethodclose

(JetlangClient client)

src/test/java/org/jetlang/remote/IntegrationBase.java:334

↓ 10 callersMethodclose

Attempts to close the underlying socket.

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

↓ 10 callersMethodgetFiber

()

src/main/java/org/jetlang/remote/acceptor/JetlangFiberSession.java:46

↓ 9 callersMethodasSubscribable

()

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

↓ 9 callersMethodcreate

(String name)

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

↓ 9 callersMethodwrite

(int byteToWrite)

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

↓ 8 callersMethodgetRemoteAddress

()

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

↓ 8 callersMethodgetSubscriptionRequestChannel

()

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

↓ 8 callersMethodnewChannel

()

src/main/java/org/jetlang/remote/acceptor/JetlangBaseSession.java:13

↓ 8 callersMethodwrap

(final Disposable subscribe)

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

↓ 7 callersMethodadd

(ByteBuffer byteBuffer)

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

↓ 7 callersMethodcontains

(String key)

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

↓ 7 callersMethodgetMessage

()

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

↓ 7 callersMethodgetTopic

()

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

↓ 7 callersMethodinit

(ContentType t, boolean fin, boolean isFragment)

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

↓ 7 callersMethodonClose

(T session)

src/main/java/org/jetlang/web/SessionFactory.java:42

↓ 7 callersMethodprint

(final String connect)

src/test/java/org/jetlang/remote/example/chat/Client.java:60

↓ 7 callersMethodsend

(String msg)

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

↓ 6 callersMethodchannel

()

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

↓ 6 callersMethodcreateCallback

()

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

↓ 6 callersMethoddispose

()

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

↓ 6 callersMethodgetRequiredBytes

()

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

↓ 6 callersMethodgetSessionCloseChannel

()

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

↓ 6 callersMethodgetSessionId

()

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

↓ 6 callersMethodonHandlerException

(Exception failed)

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

↓ 6 callersMethodpublishToAllSubscribedClients

(String topic, Object msg)

src/main/java/org/jetlang/remote/acceptor/ClientPublisher.java:10

↓ 5 callersMethodcloseOnError

(String msg)

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

↓ 5 callersMethodcreateClose

()

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

↓ 5 callersMethoddispose

()

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

↓ 5 callersMethodfind

(HttpRequest headers, T sessionState)

src/main/java/org/jetlang/web/HandlerLocator.java:14

↓ 5 callersMethodgetContentCharset

@return charset found in request or default body charset if one isn't present

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

↓ 5 callersMethodgetUnsubscribeChannel

()

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

↓ 5 callersMethodhandleDisconnect

(CloseEvent event)

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

↓ 5 callersMethodhandleDisconnect

(IOException e, ChannelState sc)

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

↓ 5 callersMethodonError

(WebSocketConnection connection, T state, String msg)

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

↓ 5 callersMethodrandomByte

()

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

↓ 5 callersMethodreply

(int reqId, String reqmsgTopic, Object replyMsg)

src/main/java/org/jetlang/remote/acceptor/JetlangMessagePublisher.java:6

↓ 5 callersMethodscheduleWithFixedDelay

(Runnable command, long initialDelay, long delay, TimeUnit unit)

src/main/java/org/jetlang/web/WebFiberConnection.java:84

↓ 5 callersMethodsend

(String msg)

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

↓ 5 callersMethodsendResponse

(int statusCode, String statusTxt, String contentType, Path resource, Charset charset)

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

↓ 5 callersMethodsplitQuery

(URI url)

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

↓ 5 callersMethodsubscribe

(Subscriber<T> channel, DisposingExecutor exec)

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

↓ 5 callersMethodtakeFromReceived

()

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

↓ 5 callersMethodtoString

()

src/test/java/org/jetlang/remote/example/ws/WebServerEchoMain.java:66

↓ 4 callersMethodadd

(PathMatcher<S> path, WebSocketHandler<S, T> handler)

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

↓ 4 callersMethodclose

()

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

↓ 4 callersMethodcreateOnNewSession

(WebSocketHandler<S, T> handler, HttpRequest headers, S sessionState)

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

↓ 4 callersMethoddoClose

()

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

↓ 4 callersMethodflush

()

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

↓ 4 callersMethodgetConnectTimeout

()

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

↓ 4 callersMethodgetReadFiber

()

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

↓ 4 callersMethodgetReadTimeoutChannel

()

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

↓ 4 callersMethodgetReconnectDelayInMs

()

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

↓ 4 callersMethodhandleDisconnect

(IOException e)

src/main/java/org/jetlang/remote/acceptor/JetlangStreamSession.java:86

↓ 4 callersMethodonException

(WebSocketConnection connection, T state, Exception failed)

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

↓ 4 callersMethodonMessage

(String dataTopicVal, Object readObject)

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

↓ 4 callersMethodonNewSession

(ClientPublisher globalPublisher, JetlangSession session)

src/main/java/org/jetlang/remote/acceptor/NewSessionHandler.java:5

↓ 4 callersMethodschedule

(Runnable command, long delay, TimeUnit unit)

src/main/java/org/jetlang/web/WebFiberConnection.java:79

↓ 4 callersMethodsetTcpNoDelay

(boolean tcpNoDelay)

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

↓ 4 callersMethodtoString

()

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

↓ 4 callersMethodtoString

()

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

↓ 4 callersMethodwrite

(String topic, Object msg)

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

↓ 4 callersMethodwriteByteAsInt

(int byteToWrite)

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

↓ 3 callersMethodadd

(String name, String value)

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

↓ 3 callersMethodappendInt

(int v)

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

↓ 3 callersMethodbodyReadinit

(int size, ContentType t, boolean fin, boolean isFragment, boolean frameMasked)

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

↓ 3 callersMethodclose

(boolean sendLogoutIfStillConnected)

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

↓ 3 callersMethodcloseOnNioFiber

()

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

↓ 3 callersMethodcreate

(int i)

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

↓ 3 callersMethoddecode

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

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

↓ 3 callersMethoddoClose

(SocketChannel newChannel, NioControls nioControls)

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

↓ 3 callersMethodexpect

(int expected, Subscriber<T> connected)

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

↓ 3 callersMethodget

(String key)

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

↓ 3 callersMethodgetBuffer

()

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

↓ 3 callersMethodgetCharset

(Path finalResource, byte[] bytes)

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

↓ 3 callersMethodgetCloseChannel

()

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

↓ 3 callersMethodgetConnectTimeoutUnit

()

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

next →1–100 of 938, ranked by callers