org.robokind.demo.robot.replication.lifecycle
Class EventBufferUtils.EventBuffer<T>

java.lang.Object
  org.jflux.api.core.playable.BasicPlayable
      org.jflux.api.core.node.DefaultConsumerNode<T>
          org.robokind.demo.robot.replication.lifecycle.EventBufferUtils.EventBuffer<T>

All Implemented Interfaces:

org.jflux.api.core.node.ConsumerNode<T>, org.jflux.api.core.node.Node, org.jflux.api.core.playable.Playable

Enclosing class:

EventBufferUtils

public static class EventBufferUtils.EventBuffer<T>
extends org.jflux.api.core.node.DefaultConsumerNode<T>

Nested Class Summary

Nested classes/interfaces inherited from interface org.jflux.api.core.playable.Playable

org.jflux.api.core.playable.Playable.PlayState

Constructor Summary

EventBufferUtils.EventBuffer(org.jflux.api.core.Adapter<T,org.jflux.api.core.event.Event<org.jflux.api.core.event.Header<String,Long>,T>> eventFactory, org.jflux.api.data.buffer.Buffer<Integer,org.jflux.api.core.event.Event<org.jflux.api.core.event.Header<String,Long>,T>> buffer, org.jflux.api.core.Adapter<org.jflux.api.core.event.Event<org.jflux.api.core.event.Header<String,Long>,T>,org.jflux.avrogen.EventRecord> eventAdapter)

Method Summary

org.jflux.api.core.Source<List<org.jflux.avrogen.EventRecord>>

getRecordValues()

Methods inherited from class org.jflux.api.core.node.DefaultConsumerNode

getListener

Methods inherited from class org.jflux.api.core.playable.BasicPlayable

complete, getPlayState, pause, resume, start, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jflux.api.core.playable.Playable

getPlayState, pause, resume, start, stop

Constructor Detail

EventBufferUtils.EventBuffer

public EventBufferUtils.EventBuffer(org.jflux.api.core.Adapter<T,org.jflux.api.core.event.Event<org.jflux.api.core.event.Header<String,Long>,T>> eventFactory,
                                    org.jflux.api.data.buffer.Buffer<Integer,org.jflux.api.core.event.Event<org.jflux.api.core.event.Header<String,Long>,T>> buffer,
                                    org.jflux.api.core.Adapter<org.jflux.api.core.event.Event<org.jflux.api.core.event.Header<String,Long>,T>,org.jflux.avrogen.EventRecord> eventAdapter)

Method Detail

getRecordValues

public org.jflux.api.core.Source<List<org.jflux.avrogen.EventRecord>> getRecordValues()