| /dports/misc/concourse/concourse-6.7.2/vendor/github.com/vito/go-sse/sse/ |
| H A D | read_closer_test.go | 17 eventStream string
25 eventStream = ""
92 eventStream += `id: 12
118 eventStream += `id: 13
179 eventStream += `id: 12
199 eventStream += `id: 12
213 eventStream += `id: 12
227 eventStream += `id: 12
248 eventStream += `id:12
268 eventStream += `id: 12
[all …]
|
| /dports/java/eclipse/eclipse.platform.releng.aggregator-R4_16/rt.equinox.bundles/bundles/org.eclipse.equinox.log.stream/osgi/src/org/osgi/util/pushstream/ |
| H A D | AbstractPushStreamImpl.java | 237 return eventStream; in filter()
258 return eventStream; in map()
309 return eventStream; in asyncMap()
357 return eventStream; in flatMap()
402 return eventStream; in sorted()
431 return eventStream; in limit()
456 return eventStream; in limit()
483 return eventStream; in timeout()
528 return eventStream; in skip()
575 return eventStream; in fork()
[all …]
|
| /dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/hashicorp/serf/cmd/serf/command/agent/ |
| H A D | ipc_event_stream.go | 16 type eventStream struct { struct
24 …ntStream(client streamClient, filters []EventFilter, seq uint64, logger *log.Logger) *eventStream {
25 es := &eventStream{
36 func (es *eventStream) HandleEvent(e serf.Event) { argument
54 func (es *eventStream) Stop() { argument
58 func (es *eventStream) stream() { argument
80 func (es *eventStream) sendMemberEvent(me serf.MemberEvent) error { argument
111 func (es *eventStream) sendUserEvent(ue serf.UserEvent) error { argument
127 func (es *eventStream) sendQuery(q *serf.Query) error { argument
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/hashicorp/serf/cmd/serf/command/agent/ |
| H A D | ipc_event_stream.go | 16 type eventStream struct { struct
24 …ntStream(client streamClient, filters []EventFilter, seq uint64, logger *log.Logger) *eventStream {
25 es := &eventStream{
36 func (es *eventStream) HandleEvent(e serf.Event) { argument
54 func (es *eventStream) Stop() { argument
58 func (es *eventStream) stream() { argument
80 func (es *eventStream) sendMemberEvent(me serf.MemberEvent) error { argument
111 func (es *eventStream) sendUserEvent(ue serf.UserEvent) error { argument
127 func (es *eventStream) sendQuery(q *serf.Query) error { argument
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/hashicorp/serf/cmd/serf/command/agent/ |
| H A D | ipc_event_stream.go | 16 type eventStream struct { struct
24 …ntStream(client streamClient, filters []EventFilter, seq uint64, logger *log.Logger) *eventStream {
25 es := &eventStream{
36 func (es *eventStream) HandleEvent(e serf.Event) { argument
54 func (es *eventStream) Stop() { argument
58 func (es *eventStream) stream() { argument
80 func (es *eventStream) sendMemberEvent(me serf.MemberEvent) error { argument
111 func (es *eventStream) sendUserEvent(ue serf.UserEvent) error { argument
127 func (es *eventStream) sendQuery(q *serf.Query) error { argument
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/hashicorp/serf/serf-0.7.0/command/agent/ |
| H A D | ipc_event_stream.go | 15 type eventStream struct { struct
23 …ntStream(client streamClient, filters []EventFilter, seq uint64, logger *log.Logger) *eventStream {
24 es := &eventStream{
35 func (es *eventStream) HandleEvent(e serf.Event) { argument
53 func (es *eventStream) Stop() { argument
57 func (es *eventStream) stream() { argument
79 func (es *eventStream) sendMemberEvent(me serf.MemberEvent) error { argument
110 func (es *eventStream) sendUserEvent(ue serf.UserEvent) error { argument
126 func (es *eventStream) sendQuery(q *serf.Query) error { argument
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/serf/cmd/serf/command/agent/ |
| H A D | ipc_event_stream.go | 16 type eventStream struct { struct
24 …ntStream(client streamClient, filters []EventFilter, seq uint64, logger *log.Logger) *eventStream {
25 es := &eventStream{
36 func (es *eventStream) HandleEvent(e serf.Event) { argument
54 func (es *eventStream) Stop() { argument
58 func (es *eventStream) stream() { argument
80 func (es *eventStream) sendMemberEvent(me serf.MemberEvent) error { argument
111 func (es *eventStream) sendUserEvent(ue serf.UserEvent) error { argument
127 func (es *eventStream) sendQuery(q *serf.Query) error { argument
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/hashicorp/serf/cmd/serf/command/agent/ |
| H A D | ipc_event_stream.go | 16 type eventStream struct { struct
24 …ntStream(client streamClient, filters []EventFilter, seq uint64, logger *log.Logger) *eventStream {
25 es := &eventStream{
36 func (es *eventStream) HandleEvent(e serf.Event) { argument
54 func (es *eventStream) Stop() { argument
58 func (es *eventStream) stream() { argument
80 func (es *eventStream) sendMemberEvent(me serf.MemberEvent) error { argument
111 func (es *eventStream) sendUserEvent(ue serf.UserEvent) error { argument
127 func (es *eventStream) sendQuery(q *serf.Query) error { argument
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/github.com/hashicorp/serf/command/agent/ |
| H A D | ipc_event_stream.go | 15 type eventStream struct { struct
23 …ntStream(client streamClient, filters []EventFilter, seq uint64, logger *log.Logger) *eventStream {
24 es := &eventStream{
35 func (es *eventStream) HandleEvent(e serf.Event) { argument
53 func (es *eventStream) Stop() { argument
57 func (es *eventStream) stream() { argument
79 func (es *eventStream) sendMemberEvent(me serf.MemberEvent) error { argument
110 func (es *eventStream) sendUserEvent(ue serf.UserEvent) error { argument
126 func (es *eventStream) sendQuery(q *serf.Query) error { argument
|
| /dports/sysutils/serf/serf-0.8.5/cmd/serf/command/agent/ |
| H A D | ipc_event_stream.go | 16 type eventStream struct { struct
24 …ntStream(client streamClient, filters []EventFilter, seq uint64, logger *log.Logger) *eventStream {
25 es := &eventStream{
36 func (es *eventStream) HandleEvent(e serf.Event) { argument
54 func (es *eventStream) Stop() { argument
58 func (es *eventStream) stream() { argument
80 func (es *eventStream) sendMemberEvent(me serf.MemberEvent) error { argument
111 func (es *eventStream) sendUserEvent(ue serf.UserEvent) error { argument
127 func (es *eventStream) sendQuery(q *serf.Query) error { argument
|
| /dports/security/lego/lego-4.5.3/vendor/github.com/aws/aws-sdk-go/private/model/api/ |
| H A D | eventstream.go | 267 eventStream := &EventStream{
271 s.EventStream = eventStream
285 eventRef.Shape.EventFor[eventStream.Name] = eventStream
292 For: eventStream,
295 eventStream.Exceptions = append(eventStream.Exceptions, event)
297 eventStream.Events = append(eventStream.Events, event)
301 return eventStream
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/github.com/aws/aws-sdk-go/private/model/api/ |
| H A D | eventstream.go | 267 eventStream := &EventStream{
271 s.EventStream = eventStream
285 eventRef.Shape.EventFor[eventStream.Name] = eventStream
292 For: eventStream,
295 eventStream.Exceptions = append(eventStream.Exceptions, event)
297 eventStream.Events = append(eventStream.Events, event)
301 return eventStream
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/aws/aws-sdk-go/private/model/api/ |
| H A D | eventstream.go | 268 eventStream := &EventStream{
272 s.EventStream = eventStream
286 eventRef.Shape.EventFor[eventStream.Name] = eventStream
293 For: eventStream,
296 eventStream.Exceptions = append(eventStream.Exceptions, event)
298 eventStream.Events = append(eventStream.Events, event)
302 return eventStream
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/aws/aws-sdk-go/private/model/api/ |
| H A D | eventstream.go | 267 eventStream := &EventStream{
271 s.EventStream = eventStream
285 eventRef.Shape.EventFor[eventStream.Name] = eventStream
292 For: eventStream,
295 eventStream.Exceptions = append(eventStream.Exceptions, event)
297 eventStream.Events = append(eventStream.Events, event)
301 return eventStream
|
| /dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/aws/aws-sdk-go/private/model/api/ |
| H A D | eventstream.go | 267 eventStream := &EventStream{
271 s.EventStream = eventStream
285 eventRef.Shape.EventFor[eventStream.Name] = eventStream
292 For: eventStream,
295 eventStream.Exceptions = append(eventStream.Exceptions, event)
297 eventStream.Events = append(eventStream.Events, event)
301 return eventStream
|
| /dports/net/rclone/rclone-1.57.0/vendor/github.com/aws/aws-sdk-go/private/model/api/ |
| H A D | eventstream.go | 268 eventStream := &EventStream{
272 s.EventStream = eventStream
286 eventRef.Shape.EventFor[eventStream.Name] = eventStream
293 For: eventStream,
296 eventStream.Exceptions = append(eventStream.Exceptions, event)
298 eventStream.Events = append(eventStream.Events, event)
302 return eventStream
|
| /dports/www/gohugo/hugo-0.91.2/vendor/github.com/aws/aws-sdk-go/private/model/api/ |
| H A D | eventstream.go | 268 eventStream := &EventStream{
272 s.EventStream = eventStream
286 eventRef.Shape.EventFor[eventStream.Name] = eventStream
293 For: eventStream,
296 eventStream.Exceptions = append(eventStream.Exceptions, event)
298 eventStream.Events = append(eventStream.Events, event)
302 return eventStream
|
| /dports/net/cloudquery/cloudquery-0.16.0/vendor/github.com/aws/aws-sdk-go/private/model/api/ |
| H A D | eventstream.go | 268 eventStream := &EventStream{
272 s.EventStream = eventStream
286 eventRef.Shape.EventFor[eventStream.Name] = eventStream
293 For: eventStream,
296 eventStream.Exceptions = append(eventStream.Exceptions, event)
298 eventStream.Events = append(eventStream.Events, event)
302 return eventStream
|
| /dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/github.com/aws/aws-sdk-go/private/model/api/ |
| H A D | eventstream.go | 267 eventStream := &EventStream{
271 s.EventStream = eventStream
285 eventRef.Shape.EventFor[eventStream.Name] = eventStream
292 For: eventStream,
295 eventStream.Exceptions = append(eventStream.Exceptions, event)
297 eventStream.Events = append(eventStream.Events, event)
301 return eventStream
|
| /dports/textproc/gitlab-elasticsearch-indexer/gitlab-elasticsearch-indexer-ef1440548effec15831eda2d246dacc43233cefb/vendor/github.com/aws/aws-sdk-go/private/model/api/ |
| H A D | eventstream.go | 267 eventStream := &EventStream{
271 s.EventStream = eventStream
285 eventRef.Shape.EventFor[eventStream.Name] = eventStream
292 For: eventStream,
295 eventStream.Exceptions = append(eventStream.Exceptions, event)
297 eventStream.Events = append(eventStream.Events, event)
301 return eventStream
|
| /dports/www/tusd/tusd-1.8.0/vendor/github.com/aws/aws-sdk-go/private/model/api/ |
| H A D | eventstream.go | 268 eventStream := &EventStream{
272 s.EventStream = eventStream
286 eventRef.Shape.EventFor[eventStream.Name] = eventStream
293 For: eventStream,
296 eventStream.Exceptions = append(eventStream.Exceptions, event)
298 eventStream.Events = append(eventStream.Events, event)
302 return eventStream
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/aws/aws-sdk-go/private/model/api/ |
| H A D | eventstream.go | 268 eventStream := &EventStream{
272 s.EventStream = eventStream
286 eventRef.Shape.EventFor[eventStream.Name] = eventStream
293 For: eventStream,
296 eventStream.Exceptions = append(eventStream.Exceptions, event)
298 eventStream.Events = append(eventStream.Events, event)
302 return eventStream
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/aws/aws-sdk-go/private/model/api/ |
| H A D | eventstream.go | 267 eventStream := &EventStream{
271 s.EventStream = eventStream
285 eventRef.Shape.EventFor[eventStream.Name] = eventStream
292 For: eventStream,
295 eventStream.Exceptions = append(eventStream.Exceptions, event)
297 eventStream.Events = append(eventStream.Events, event)
301 return eventStream
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/github.com/aws/aws-sdk-go/private/model/api/ |
| H A D | eventstream.go | 268 eventStream := &EventStream{
272 s.EventStream = eventStream
286 eventRef.Shape.EventFor[eventStream.Name] = eventStream
293 For: eventStream,
296 eventStream.Exceptions = append(eventStream.Exceptions, event)
298 eventStream.Events = append(eventStream.Events, event)
302 return eventStream
|
| /dports/games/openclonk/openclonk-release-8.1-src/src/platform/ |
| H A D | C4FileMonitorMac.mm | 29 eventStream = NULL;
72 …eventStream = FSEventStreamCreate(kCFAllocatorDefault, &FSEvents_Callback, &context, (__bridge CFA…
74 FSEventStreamScheduleWithRunLoop(eventStream, CFRunLoopGetCurrent(), kCFRunLoopDefaultMode);
75 FSEventStreamStart(eventStream);
83 FSEventStreamStop(eventStream);
84 FSEventStreamInvalidate(eventStream);
85 FSEventStreamRelease(eventStream);
|