Class TimebaseTestUtils.IterableMessageSource<T>

  • All Implemented Interfaces:
    deltix.data.stream.MessageSource<T>, deltix.util.concurrent.AbstractCursor, deltix.util.lang.Disposable, java.io.Closeable, java.lang.AutoCloseable
    Enclosing class:
    TimebaseTestUtils

    public static class TimebaseTestUtils.IterableMessageSource<T>
    extends java.lang.Object
    implements deltix.data.stream.MessageSource<T>
    • Constructor Detail

      • IterableMessageSource

        @SafeVarargs
        public IterableMessageSource​(T... messages)
      • IterableMessageSource

        public IterableMessageSource​(java.lang.Iterable<? extends T> source)
    • Method Detail

      • reset

        public void reset()
      • getMessage

        public T getMessage()
        Specified by:
        getMessage in interface deltix.data.stream.MessageSource<T>
      • next

        public boolean next()
        Specified by:
        next in interface deltix.util.concurrent.AbstractCursor
      • isAtEnd

        public boolean isAtEnd()
        Specified by:
        isAtEnd in interface deltix.util.concurrent.AbstractCursor
      • close

        public void close()
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Specified by:
        close in interface deltix.util.lang.Disposable