MCPcopy Create free account

hub / github.com/antage/eventsource / functions

Functions34 in github.com/antage/eventsource

⨍ Functions 34◇ Types & classes 9
↓ 20 callersMethodClose
close and clear all consumers
eventsource.go:91
↓ 11 callersMethodSendEventMessage
send message to all consumers
eventsource.go:82
↓ 11 callersFunctionexpectResponse
(t *testing.T, c net.Conn, expecting string)
eventsource_test.go:85
↓ 8 callersMethodWrite
(b []byte)
consumer.go:24
↓ 8 callersFunctionstartEventStream
(t *testing.T, e *testEnv)
eventsource_test.go:71
↓ 6 callersFunctionteardown
(t *testing.T, e *testEnv)
eventsource_test.go:50
↓ 4 callersFunctionsetup
(t *testing.T)
eventsource_test.go:18
↓ 3 callersMethodConsumersCount
consumers count
eventsource.go:88
↓ 3 callersFunctionNew
New creates new EventSource instance.
eventsource.go:192
↓ 2 callersFunctionDefaultSettings
()
eventsource.go:67
↓ 2 callersFunctioncheckError
(t *testing.T, e error)
eventsource_test.go:56
↓ 2 callersFunctionread
(t *testing.T, c net.Conn)
eventsource_test.go:62
↓ 2 callersMethodsendMessage
(m message)
eventsource.go:226
↓ 1 callersMethodSendRetryMessage
send retry message to all consumers
eventsource.go:85
↓ 1 callersFunctioncontrolProcess
(es *eventSource)
eventsource.go:117
↓ 1 callersFunctionnewConsumer
(resp http.ResponseWriter, req *http.Request, es *eventSource)
consumer.go:42
↓ 1 callersMethodprepareMessage
The message to be sent to clients
eventsource.go:96
↓ 1 callersFunctionsetupWithCustomSettings
(t *testing.T, settings *Settings)
eventsource_test.go:39
↓ 1 callersFunctionsetupWithHeaders
(t *testing.T, headers [][]byte)
eventsource_test.go:26
MethodClose
()
consumer.go:33
MethodClose
()
eventsource.go:212
MethodConsumersCount
()
eventsource.go:243
MethodSendEventMessage
(data, event, id string)
eventsource.go:230
MethodSendRetryMessage
(t time.Duration)
eventsource.go:239
MethodServeHTTP
ServeHTTP implements http.Handler interface.
eventsource.go:217
FunctionTestConnection
(t *testing.T)
eventsource_test.go:94
FunctionTestConnectionWithCustomHeaders
(t *testing.T)
eventsource_test.go:110
FunctionTestEventMessageSending
(t *testing.T)
eventsource_test.go:149
FunctionTestIdleTimeout
(t *testing.T)
eventsource_test.go:212
FunctionTestRetryMessageSending
(t *testing.T)
eventsource_test.go:137
FunctionTestStalledMessages
(t *testing.T)
eventsource_test.go:181
Functionmain
()
examples/greeter.go:10
MethodprepareMessage
()
eventsource.go:99
MethodprepareMessage
()
eventsource.go:235