mock

package
v1.4.0-alpha Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 19, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

Package mock is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Stream 

func Stream(items ...interface{}) rx.Stream

Stream mocks a rx.Stream with items slice.

func StreamWithInterval 

func StreamWithInterval(interval time.Duration, items ...interface{}) rx.Stream

StreamWithInterval mocks a rx.Stream with items slice.

Types

type MockStream 

type MockStream struct {
	// contains filtered or unexported fields
}

MockStream is a mock of Stream interface.

func NewMockStream 

func NewMockStream(ctrl *gomock.Controller) *MockStream

NewMockStream creates a new mock instance.

func (*MockStream) All 

func (m *MockStream) All(predicate rxgo.Predicate, opts ...rxgo.Option) rx.Stream

All mocks base method.

func (*MockStream) AuditTime 

func (m *MockStream) AuditTime(milliseconds uint32, opts ...rxgo.Option) rx.Stream

AuditTime mocks base method.

func (*MockStream) AverageFloat32 

func (m *MockStream) AverageFloat32(opts ...rxgo.Option) rx.Stream

AverageFloat32 mocks base method.

func (*MockStream) AverageFloat64 

func (m *MockStream) AverageFloat64(opts ...rxgo.Option) rx.Stream

AverageFloat64 mocks base method.

func (*MockStream) AverageInt 

func (m *MockStream) AverageInt(opts ...rxgo.Option) rx.Stream

AverageInt mocks base method.

func (*MockStream) AverageInt16 

func (m *MockStream) AverageInt16(opts ...rxgo.Option) rx.Stream

AverageInt16 mocks base method.

func (*MockStream) AverageInt32 

func (m *MockStream) AverageInt32(opts ...rxgo.Option) rx.Stream

AverageInt32 mocks base method.

func (*MockStream) AverageInt64 

func (m *MockStream) AverageInt64(opts ...rxgo.Option) rx.Stream

AverageInt64 mocks base method.

func (*MockStream) AverageInt8 

func (m *MockStream) AverageInt8(opts ...rxgo.Option) rx.Stream

AverageInt8 mocks base method.

func (*MockStream) BackOffRetry 

func (m *MockStream) BackOffRetry(backOffCfg backoff.BackOff, opts ...rxgo.Option) rx.Stream

BackOffRetry mocks base method.

func (*MockStream) BufferWithCount 

func (m *MockStream) BufferWithCount(count int, opts ...rxgo.Option) rx.Stream

BufferWithCount mocks base method.

func (*MockStream) BufferWithTime 

func (m *MockStream) BufferWithTime(milliseconds uint32, opts ...rxgo.Option) rx.Stream

BufferWithTime mocks base method.

func (*MockStream) BufferWithTimeOrCount 

func (m *MockStream) BufferWithTimeOrCount(milliseconds uint32, count int, opts ...rxgo.Option) rx.Stream

BufferWithTimeOrCount mocks base method.

func (*MockStream) Connect 

func (m *MockStream) Connect(ctx context.Context) (context.Context, rxgo.Disposable)

Connect mocks base method.

func (*MockStream) Contains 

func (m *MockStream) Contains(equal rxgo.Predicate, opts ...rxgo.Option) rx.Stream

Contains mocks base method.

func (*MockStream) Count 

func (m *MockStream) Count(opts ...rxgo.Option) rx.Stream

Count mocks base method.

func (*MockStream) Debounce 

func (m *MockStream) Debounce(milliseconds uint32, opts ...rxgo.Option) rx.Stream

Debounce mocks base method.

func (*MockStream) DefaultIfEmpty 

func (m *MockStream) DefaultIfEmpty(defaultValue interface{}, opts ...rxgo.Option) rx.Stream

DefaultIfEmpty mocks base method.

func (*MockStream) DefaultIfEmptyWithTime 

func (m *MockStream) DefaultIfEmptyWithTime(milliseconds uint32, defaultValue interface{}, opts ...rxgo.Option) rx.Stream

DefaultIfEmptyWithTime mocks base method.

func (*MockStream) Distinct 

func (m *MockStream) Distinct(apply rxgo.Func, opts ...rxgo.Option) rx.Stream

Distinct mocks base method.

func (*MockStream) DistinctUntilChanged 

func (m *MockStream) DistinctUntilChanged(apply rxgo.Func, opts ...rxgo.Option) rx.Stream

DistinctUntilChanged mocks base method.

func (*MockStream) DoOnCompleted 

func (m *MockStream) DoOnCompleted(completedFunc rxgo.CompletedFunc, opts ...rxgo.Option) rxgo.Disposed

DoOnCompleted mocks base method.

func (*MockStream) DoOnError 

func (m *MockStream) DoOnError(errFunc rxgo.ErrFunc, opts ...rxgo.Option) rxgo.Disposed

DoOnError mocks base method.

func (*MockStream) DoOnNext 

func (m *MockStream) DoOnNext(nextFunc rxgo.NextFunc, opts ...rxgo.Option) rxgo.Disposed

DoOnNext mocks base method.

func (*MockStream) EXPECT 

func (m *MockStream) EXPECT() *MockStreamMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockStream) ElementAt 

func (m *MockStream) ElementAt(index uint, opts ...rxgo.Option) rx.Stream

ElementAt mocks base method.

func (*MockStream) Encode 

func (m *MockStream) Encode(key byte, opts ...rxgo.Option) rx.Stream

Encode mocks base method.

func (*MockStream) Error 

func (m *MockStream) Error(opts ...rxgo.Option) error

Error mocks base method.

func (*MockStream) Errors 

func (m *MockStream) Errors(opts ...rxgo.Option) []error

Errors mocks base method.

func (*MockStream) Filter 

func (m *MockStream) Filter(apply rxgo.Predicate, opts ...rxgo.Option) rx.Stream

Filter mocks base method.

func (*MockStream) Find 

func (m *MockStream) Find(find rxgo.Predicate, opts ...rxgo.Option) rx.Stream

Find mocks base method.

func (*MockStream) First 

func (m *MockStream) First(opts ...rxgo.Option) rx.Stream

First mocks base method.

func (*MockStream) FirstOrDefault 

func (m *MockStream) FirstOrDefault(defaultValue interface{}, opts ...rxgo.Option) rx.Stream

FirstOrDefault mocks base method.

func (*MockStream) FlatMap 

func (m *MockStream) FlatMap(apply rxgo.ItemToObservable, opts ...rxgo.Option) rx.Stream

FlatMap mocks base method.

func (*MockStream) ForEach 

func (m *MockStream) ForEach(nextFunc rxgo.NextFunc, errFunc rxgo.ErrFunc, completedFunc rxgo.CompletedFunc, opts ...rxgo.Option) rxgo.Disposed

ForEach mocks base method.

func (*MockStream) GroupBy 

func (m *MockStream) GroupBy(length int, distribution func(rxgo.Item) int, opts ...rxgo.Option) rx.Stream

GroupBy mocks base method.

func (*MockStream) GroupByDynamic 

func (m *MockStream) GroupByDynamic(distribution func(rxgo.Item) string, opts ...rxgo.Option) rx.Stream

GroupByDynamic mocks base method.

func (*MockStream) IgnoreElements 

func (m *MockStream) IgnoreElements(opts ...rxgo.Option) rx.Stream

IgnoreElements mocks base method.

func (*MockStream) Join 

func (m *MockStream) Join(joiner rxgo.Func2, right rxgo.Observable, timeExtractor func(interface{}) time.Time, windowInMS uint32, opts ...rxgo.Option) rx.Stream

Join mocks base method.

func (*MockStream) Last 

func (m *MockStream) Last(opts ...rxgo.Option) rx.Stream

Last mocks base method.

func (*MockStream) LastOrDefault 

func (m *MockStream) LastOrDefault(defaultValue interface{}, opts ...rxgo.Option) rx.Stream

LastOrDefault mocks base method.

func (*MockStream) Map 

func (m *MockStream) Map(apply rxgo.Func, opts ...rxgo.Option) rx.Stream

Map mocks base method.

func (*MockStream) Marshal 

func (m *MockStream) Marshal(marshaller decoder.Marshaller, opts ...rxgo.Option) rx.Stream

Marshal mocks base method.

func (*MockStream) Max 

func (m *MockStream) Max(comparator rxgo.Comparator, opts ...rxgo.Option) rx.Stream

Max mocks base method.

func (*MockStream) Min 

func (m *MockStream) Min(comparator rxgo.Comparator, opts ...rxgo.Option) rx.Stream

Min mocks base method.

func (*MockStream) Observe 

func (m *MockStream) Observe(opts ...rxgo.Option) <-chan rxgo.Item

Observe mocks base method.

func (*MockStream) OnErrorResumeNext 

func (m *MockStream) OnErrorResumeNext(resumeSequence rxgo.ErrorToObservable, opts ...rxgo.Option) rx.Stream

OnErrorResumeNext mocks base method.

func (*MockStream) OnErrorReturn 

func (m *MockStream) OnErrorReturn(resumeFunc rxgo.ErrorFunc, opts ...rxgo.Option) rx.Stream

OnErrorReturn mocks base method.

func (*MockStream) OnErrorReturnItem 

func (m *MockStream) OnErrorReturnItem(resume interface{}, opts ...rxgo.Option) rx.Stream

OnErrorReturnItem mocks base method.

func (*MockStream) OnObserve 

func (m *MockStream) OnObserve(function func([]byte) (interface{}, error)) rx.Stream

OnObserve mocks base method.

func (*MockStream) RawBytes 

func (m *MockStream) RawBytes() rx.Stream

RawBytes mocks base method.

func (*MockStream) Reduce 

func (m *MockStream) Reduce(apply rxgo.Func2, opts ...rxgo.Option) rx.Stream

Reduce mocks base method.

func (*MockStream) Repeat 

func (m *MockStream) Repeat(count int64, milliseconds uint32, opts ...rxgo.Option) rx.Stream

Repeat mocks base method.

func (*MockStream) Retry 

func (m *MockStream) Retry(count int, shouldRetry func(error) bool, opts ...rxgo.Option) rx.Stream

Retry mocks base method.

func (*MockStream) Run 

func (m *MockStream) Run(opts ...rxgo.Option) rxgo.Disposed

Run mocks base method.

func (*MockStream) Sample 

func (m *MockStream) Sample(iterable rxgo.Iterable, opts ...rxgo.Option) rx.Stream

Sample mocks base method.

func (*MockStream) Scan 

func (m *MockStream) Scan(apply rxgo.Func2, opts ...rxgo.Option) rx.Stream

Scan mocks base method.

func (*MockStream) Send 

func (m *MockStream) Send(output chan<- rxgo.Item, opts ...rxgo.Option)

Send mocks base method.

func (*MockStream) SequenceEqual 

func (m *MockStream) SequenceEqual(iterable rxgo.Iterable, opts ...rxgo.Option) rx.Stream

SequenceEqual mocks base method.

func (*MockStream) Serialize 

func (m *MockStream) Serialize(from int, identifier func(interface{}) int, opts ...rxgo.Option) rx.Stream

Serialize mocks base method.

func (*MockStream) Skip 

func (m *MockStream) Skip(nth uint, opts ...rxgo.Option) rx.Stream

Skip mocks base method.

func (*MockStream) SkipLast 

func (m *MockStream) SkipLast(nth uint, opts ...rxgo.Option) rx.Stream

SkipLast mocks base method.

func (*MockStream) SkipWhile 

func (m *MockStream) SkipWhile(apply rxgo.Predicate, opts ...rxgo.Option) rx.Stream

SkipWhile mocks base method.

func (*MockStream) SlidingWindowWithCount 

func (m *MockStream) SlidingWindowWithCount(windowSize, slideSize int, handler rx.Handler, opts ...rxgo.Option) rx.Stream

SlidingWindowWithCount mocks base method.

func (*MockStream) SlidingWindowWithTime 

func (m *MockStream) SlidingWindowWithTime(windowTimeInMS, slideTimeInMS uint32, handler rx.Handler, opts ...rxgo.Option) rx.Stream

SlidingWindowWithTime mocks base method.

func (*MockStream) StartWith 

func (m *MockStream) StartWith(iterable rxgo.Iterable, opts ...rxgo.Option) rx.Stream

StartWith mocks base method.

func (*MockStream) StdOut 

func (m *MockStream) StdOut(opts ...rxgo.Option) rx.Stream

StdOut mocks base method.

func (*MockStream) Subscribe 

func (m *MockStream) Subscribe(key byte) rx.Stream

Subscribe mocks base method.

func (*MockStream) SumFloat32 

func (m *MockStream) SumFloat32(opts ...rxgo.Option) rx.Stream

SumFloat32 mocks base method.

func (*MockStream) SumFloat64 

func (m *MockStream) SumFloat64(opts ...rxgo.Option) rx.Stream

SumFloat64 mocks base method.

func (*MockStream) SumInt64 

func (m *MockStream) SumInt64(opts ...rxgo.Option) rx.Stream

SumInt64 mocks base method.

func (*MockStream) Take 

func (m *MockStream) Take(nth uint, opts ...rxgo.Option) rx.Stream

Take mocks base method.

func (*MockStream) TakeLast 

func (m *MockStream) TakeLast(nth uint, opts ...rxgo.Option) rx.Stream

TakeLast mocks base method.

func (*MockStream) TakeUntil 

func (m *MockStream) TakeUntil(apply rxgo.Predicate, opts ...rxgo.Option) rx.Stream

TakeUntil mocks base method.

func (*MockStream) TakeWhile 

func (m *MockStream) TakeWhile(apply rxgo.Predicate, opts ...rxgo.Option) rx.Stream

TakeWhile mocks base method.

func (*MockStream) TimeInterval 

func (m *MockStream) TimeInterval(opts ...rxgo.Option) rx.Stream

TimeInterval mocks base method.

func (*MockStream) Timestamp 

func (m *MockStream) Timestamp(opts ...rxgo.Option) rx.Stream

Timestamp mocks base method.

func (*MockStream) ToMap 

func (m *MockStream) ToMap(keySelector rxgo.Func, opts ...rxgo.Option) rx.Stream

ToMap mocks base method.

func (*MockStream) ToMapWithValueSelector 

func (m *MockStream) ToMapWithValueSelector(keySelector, valueSelector rxgo.Func, opts ...rxgo.Option) rx.Stream

ToMapWithValueSelector mocks base method.

func (*MockStream) ToSlice 

func (m *MockStream) ToSlice(initialCapacity int, opts ...rxgo.Option) ([]interface{}, error)

ToSlice mocks base method.

func (*MockStream) Unmarshal 

func (m *MockStream) Unmarshal(unmarshaller decoder.Unmarshaller, factory func() interface{}, opts ...rxgo.Option) rx.Stream

Unmarshal mocks base method.

func (*MockStream) WindowWithCount 

func (m *MockStream) WindowWithCount(count int, opts ...rxgo.Option) rx.Stream

WindowWithCount mocks base method.

func (*MockStream) WindowWithTime 

func (m *MockStream) WindowWithTime(milliseconds uint32, opts ...rxgo.Option) rx.Stream

WindowWithTime mocks base method.

func (*MockStream) WindowWithTimeOrCount 

func (m *MockStream) WindowWithTimeOrCount(milliseconds uint32, count int, opts ...rxgo.Option) rx.Stream

WindowWithTimeOrCount mocks base method.

func (*MockStream) ZipFromIterable 

func (m *MockStream) ZipFromIterable(iterable rxgo.Iterable, zipper rxgo.Func2, opts ...rxgo.Option) rx.Stream

ZipFromIterable mocks base method.

func (*MockStream) ZipMultiObservers 

func (m *MockStream) ZipMultiObservers(observers []rx.KeyObserveFunc, zipper func([]interface{}) (interface{}, error)) rx.Stream

ZipMultiObservers mocks base method.

type MockStreamMockRecorder 

type MockStreamMockRecorder struct {
	// contains filtered or unexported fields
}

MockStreamMockRecorder is the mock recorder for MockStream.

func (*MockStreamMockRecorder) All 

func (mr *MockStreamMockRecorder) All(predicate interface{}, opts ...interface{}) *gomock.Call

All indicates an expected call of All.

func (*MockStreamMockRecorder) AuditTime 

func (mr *MockStreamMockRecorder) AuditTime(milliseconds interface{}, opts ...interface{}) *gomock.Call

AuditTime indicates an expected call of AuditTime.

func (*MockStreamMockRecorder) AverageFloat32 

func (mr *MockStreamMockRecorder) AverageFloat32(opts ...interface{}) *gomock.Call

AverageFloat32 indicates an expected call of AverageFloat32.

func (*MockStreamMockRecorder) AverageFloat64 

func (mr *MockStreamMockRecorder) AverageFloat64(opts ...interface{}) *gomock.Call

AverageFloat64 indicates an expected call of AverageFloat64.

func (*MockStreamMockRecorder) AverageInt 

func (mr *MockStreamMockRecorder) AverageInt(opts ...interface{}) *gomock.Call

AverageInt indicates an expected call of AverageInt.

func (*MockStreamMockRecorder) AverageInt16 

func (mr *MockStreamMockRecorder) AverageInt16(opts ...interface{}) *gomock.Call

AverageInt16 indicates an expected call of AverageInt16.

func (*MockStreamMockRecorder) AverageInt32 

func (mr *MockStreamMockRecorder) AverageInt32(opts ...interface{}) *gomock.Call

AverageInt32 indicates an expected call of AverageInt32.

func (*MockStreamMockRecorder) AverageInt64 

func (mr *MockStreamMockRecorder) AverageInt64(opts ...interface{}) *gomock.Call

AverageInt64 indicates an expected call of AverageInt64.

func (*MockStreamMockRecorder) AverageInt8 

func (mr *MockStreamMockRecorder) AverageInt8(opts ...interface{}) *gomock.Call

AverageInt8 indicates an expected call of AverageInt8.

func (*MockStreamMockRecorder) BackOffRetry 

func (mr *MockStreamMockRecorder) BackOffRetry(backOffCfg interface{}, opts ...interface{}) *gomock.Call

BackOffRetry indicates an expected call of BackOffRetry.

func (*MockStreamMockRecorder) BufferWithCount 

func (mr *MockStreamMockRecorder) BufferWithCount(count interface{}, opts ...interface{}) *gomock.Call

BufferWithCount indicates an expected call of BufferWithCount.

func (*MockStreamMockRecorder) BufferWithTime 

func (mr *MockStreamMockRecorder) BufferWithTime(milliseconds interface{}, opts ...interface{}) *gomock.Call

BufferWithTime indicates an expected call of BufferWithTime.

func (*MockStreamMockRecorder) BufferWithTimeOrCount 

func (mr *MockStreamMockRecorder) BufferWithTimeOrCount(milliseconds, count interface{}, opts ...interface{}) *gomock.Call

BufferWithTimeOrCount indicates an expected call of BufferWithTimeOrCount.

func (*MockStreamMockRecorder) Connect 

func (mr *MockStreamMockRecorder) Connect(ctx interface{}) *gomock.Call

Connect indicates an expected call of Connect.

func (*MockStreamMockRecorder) Contains 

func (mr *MockStreamMockRecorder) Contains(equal interface{}, opts ...interface{}) *gomock.Call

Contains indicates an expected call of Contains.

func (*MockStreamMockRecorder) Count 

func (mr *MockStreamMockRecorder) Count(opts ...interface{}) *gomock.Call

Count indicates an expected call of Count.

func (*MockStreamMockRecorder) Debounce 

func (mr *MockStreamMockRecorder) Debounce(milliseconds interface{}, opts ...interface{}) *gomock.Call

Debounce indicates an expected call of Debounce.

func (*MockStreamMockRecorder) DefaultIfEmpty 

func (mr *MockStreamMockRecorder) DefaultIfEmpty(defaultValue interface{}, opts ...interface{}) *gomock.Call

DefaultIfEmpty indicates an expected call of DefaultIfEmpty.

func (*MockStreamMockRecorder) DefaultIfEmptyWithTime 

func (mr *MockStreamMockRecorder) DefaultIfEmptyWithTime(milliseconds, defaultValue interface{}, opts ...interface{}) *gomock.Call

DefaultIfEmptyWithTime indicates an expected call of DefaultIfEmptyWithTime.

func (*MockStreamMockRecorder) Distinct 

func (mr *MockStreamMockRecorder) Distinct(apply interface{}, opts ...interface{}) *gomock.Call

Distinct indicates an expected call of Distinct.

func (*MockStreamMockRecorder) DistinctUntilChanged 

func (mr *MockStreamMockRecorder) DistinctUntilChanged(apply interface{}, opts ...interface{}) *gomock.Call

DistinctUntilChanged indicates an expected call of DistinctUntilChanged.

func (*MockStreamMockRecorder) DoOnCompleted 

func (mr *MockStreamMockRecorder) DoOnCompleted(completedFunc interface{}, opts ...interface{}) *gomock.Call

DoOnCompleted indicates an expected call of DoOnCompleted.

func (*MockStreamMockRecorder) DoOnError 

func (mr *MockStreamMockRecorder) DoOnError(errFunc interface{}, opts ...interface{}) *gomock.Call

DoOnError indicates an expected call of DoOnError.

func (*MockStreamMockRecorder) DoOnNext 

func (mr *MockStreamMockRecorder) DoOnNext(nextFunc interface{}, opts ...interface{}) *gomock.Call

DoOnNext indicates an expected call of DoOnNext.

func (*MockStreamMockRecorder) ElementAt 

func (mr *MockStreamMockRecorder) ElementAt(index interface{}, opts ...interface{}) *gomock.Call

ElementAt indicates an expected call of ElementAt.

func (*MockStreamMockRecorder) Encode 

func (mr *MockStreamMockRecorder) Encode(key interface{}, opts ...interface{}) *gomock.Call

Encode indicates an expected call of Encode.

func (*MockStreamMockRecorder) Error 

func (mr *MockStreamMockRecorder) Error(opts ...interface{}) *gomock.Call

Error indicates an expected call of Error.

func (*MockStreamMockRecorder) Errors 

func (mr *MockStreamMockRecorder) Errors(opts ...interface{}) *gomock.Call

Errors indicates an expected call of Errors.

func (*MockStreamMockRecorder) Filter 

func (mr *MockStreamMockRecorder) Filter(apply interface{}, opts ...interface{}) *gomock.Call

Filter indicates an expected call of Filter.

func (*MockStreamMockRecorder) Find 

func (mr *MockStreamMockRecorder) Find(find interface{}, opts ...interface{}) *gomock.Call

Find indicates an expected call of Find.

func (*MockStreamMockRecorder) First 

func (mr *MockStreamMockRecorder) First(opts ...interface{}) *gomock.Call

First indicates an expected call of First.

func (*MockStreamMockRecorder) FirstOrDefault 

func (mr *MockStreamMockRecorder) FirstOrDefault(defaultValue interface{}, opts ...interface{}) *gomock.Call

FirstOrDefault indicates an expected call of FirstOrDefault.

func (*MockStreamMockRecorder) FlatMap 

func (mr *MockStreamMockRecorder) FlatMap(apply interface{}, opts ...interface{}) *gomock.Call

FlatMap indicates an expected call of FlatMap.

func (*MockStreamMockRecorder) ForEach 

func (mr *MockStreamMockRecorder) ForEach(nextFunc, errFunc, completedFunc interface{}, opts ...interface{}) *gomock.Call

ForEach indicates an expected call of ForEach.

func (*MockStreamMockRecorder) GroupBy 

func (mr *MockStreamMockRecorder) GroupBy(length, distribution interface{}, opts ...interface{}) *gomock.Call

GroupBy indicates an expected call of GroupBy.

func (*MockStreamMockRecorder) GroupByDynamic 

func (mr *MockStreamMockRecorder) GroupByDynamic(distribution interface{}, opts ...interface{}) *gomock.Call

GroupByDynamic indicates an expected call of GroupByDynamic.

func (*MockStreamMockRecorder) IgnoreElements 

func (mr *MockStreamMockRecorder) IgnoreElements(opts ...interface{}) *gomock.Call

IgnoreElements indicates an expected call of IgnoreElements.

func (*MockStreamMockRecorder) Join 

func (mr *MockStreamMockRecorder) Join(joiner, right, timeExtractor, windowInMS interface{}, opts ...interface{}) *gomock.Call

Join indicates an expected call of Join.

func (*MockStreamMockRecorder) Last 

func (mr *MockStreamMockRecorder) Last(opts ...interface{}) *gomock.Call

Last indicates an expected call of Last.

func (*MockStreamMockRecorder) LastOrDefault 

func (mr *MockStreamMockRecorder) LastOrDefault(defaultValue interface{}, opts ...interface{}) *gomock.Call

LastOrDefault indicates an expected call of LastOrDefault.

func (*MockStreamMockRecorder) Map 

func (mr *MockStreamMockRecorder) Map(apply interface{}, opts ...interface{}) *gomock.Call

Map indicates an expected call of Map.

func (*MockStreamMockRecorder) Marshal 

func (mr *MockStreamMockRecorder) Marshal(marshaller interface{}, opts ...interface{}) *gomock.Call

Marshal indicates an expected call of Marshal.

func (*MockStreamMockRecorder) Max 

func (mr *MockStreamMockRecorder) Max(comparator interface{}, opts ...interface{}) *gomock.Call

Max indicates an expected call of Max.

func (*MockStreamMockRecorder) Min 

func (mr *MockStreamMockRecorder) Min(comparator interface{}, opts ...interface{}) *gomock.Call

Min indicates an expected call of Min.

func (*MockStreamMockRecorder) Observe 

func (mr *MockStreamMockRecorder) Observe(opts ...interface{}) *gomock.Call

Observe indicates an expected call of Observe.

func (*MockStreamMockRecorder) OnErrorResumeNext 

func (mr *MockStreamMockRecorder) OnErrorResumeNext(resumeSequence interface{}, opts ...interface{}) *gomock.Call

OnErrorResumeNext indicates an expected call of OnErrorResumeNext.

func (*MockStreamMockRecorder) OnErrorReturn 

func (mr *MockStreamMockRecorder) OnErrorReturn(resumeFunc interface{}, opts ...interface{}) *gomock.Call

OnErrorReturn indicates an expected call of OnErrorReturn.

func (*MockStreamMockRecorder) OnErrorReturnItem 

func (mr *MockStreamMockRecorder) OnErrorReturnItem(resume interface{}, opts ...interface{}) *gomock.Call

OnErrorReturnItem indicates an expected call of OnErrorReturnItem.

func (*MockStreamMockRecorder) OnObserve 

func (mr *MockStreamMockRecorder) OnObserve(function interface{}) *gomock.Call

OnObserve indicates an expected call of OnObserve.

func (*MockStreamMockRecorder) RawBytes 

func (mr *MockStreamMockRecorder) RawBytes() *gomock.Call

RawBytes indicates an expected call of RawBytes.

func (*MockStreamMockRecorder) Reduce 

func (mr *MockStreamMockRecorder) Reduce(apply interface{}, opts ...interface{}) *gomock.Call

Reduce indicates an expected call of Reduce.

func (*MockStreamMockRecorder) Repeat 

func (mr *MockStreamMockRecorder) Repeat(count, milliseconds interface{}, opts ...interface{}) *gomock.Call

Repeat indicates an expected call of Repeat.

func (*MockStreamMockRecorder) Retry 

func (mr *MockStreamMockRecorder) Retry(count, shouldRetry interface{}, opts ...interface{}) *gomock.Call

Retry indicates an expected call of Retry.

func (*MockStreamMockRecorder) Run 

func (mr *MockStreamMockRecorder) Run(opts ...interface{}) *gomock.Call

Run indicates an expected call of Run.

func (*MockStreamMockRecorder) Sample 

func (mr *MockStreamMockRecorder) Sample(iterable interface{}, opts ...interface{}) *gomock.Call

Sample indicates an expected call of Sample.

func (*MockStreamMockRecorder) Scan 

func (mr *MockStreamMockRecorder) Scan(apply interface{}, opts ...interface{}) *gomock.Call

Scan indicates an expected call of Scan.

func (*MockStreamMockRecorder) Send 

func (mr *MockStreamMockRecorder) Send(output interface{}, opts ...interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockStreamMockRecorder) SequenceEqual 

func (mr *MockStreamMockRecorder) SequenceEqual(iterable interface{}, opts ...interface{}) *gomock.Call

SequenceEqual indicates an expected call of SequenceEqual.

func (*MockStreamMockRecorder) Serialize 

func (mr *MockStreamMockRecorder) Serialize(from, identifier interface{}, opts ...interface{}) *gomock.Call

Serialize indicates an expected call of Serialize.

func (*MockStreamMockRecorder) Skip 

func (mr *MockStreamMockRecorder) Skip(nth interface{}, opts ...interface{}) *gomock.Call

Skip indicates an expected call of Skip.

func (*MockStreamMockRecorder) SkipLast 

func (mr *MockStreamMockRecorder) SkipLast(nth interface{}, opts ...interface{}) *gomock.Call

SkipLast indicates an expected call of SkipLast.

func (*MockStreamMockRecorder) SkipWhile 

func (mr *MockStreamMockRecorder) SkipWhile(apply interface{}, opts ...interface{}) *gomock.Call

SkipWhile indicates an expected call of SkipWhile.

func (*MockStreamMockRecorder) SlidingWindowWithCount 

func (mr *MockStreamMockRecorder) SlidingWindowWithCount(windowSize, slideSize, handler interface{}, opts ...interface{}) *gomock.Call

SlidingWindowWithCount indicates an expected call of SlidingWindowWithCount.

func (*MockStreamMockRecorder) SlidingWindowWithTime 

func (mr *MockStreamMockRecorder) SlidingWindowWithTime(windowTimeInMS, slideTimeInMS, handler interface{}, opts ...interface{}) *gomock.Call

SlidingWindowWithTime indicates an expected call of SlidingWindowWithTime.

func (*MockStreamMockRecorder) StartWith 

func (mr *MockStreamMockRecorder) StartWith(iterable interface{}, opts ...interface{}) *gomock.Call

StartWith indicates an expected call of StartWith.

func (*MockStreamMockRecorder) StdOut 

func (mr *MockStreamMockRecorder) StdOut(opts ...interface{}) *gomock.Call

StdOut indicates an expected call of StdOut.

func (*MockStreamMockRecorder) Subscribe 

func (mr *MockStreamMockRecorder) Subscribe(key interface{}) *gomock.Call

Subscribe indicates an expected call of Subscribe.

func (*MockStreamMockRecorder) SumFloat32 

func (mr *MockStreamMockRecorder) SumFloat32(opts ...interface{}) *gomock.Call

SumFloat32 indicates an expected call of SumFloat32.

func (*MockStreamMockRecorder) SumFloat64 

func (mr *MockStreamMockRecorder) SumFloat64(opts ...interface{}) *gomock.Call

SumFloat64 indicates an expected call of SumFloat64.

func (*MockStreamMockRecorder) SumInt64 

func (mr *MockStreamMockRecorder) SumInt64(opts ...interface{}) *gomock.Call

SumInt64 indicates an expected call of SumInt64.

func (*MockStreamMockRecorder) Take 

func (mr *MockStreamMockRecorder) Take(nth interface{}, opts ...interface{}) *gomock.Call

Take indicates an expected call of Take.

func (*MockStreamMockRecorder) TakeLast 

func (mr *MockStreamMockRecorder) TakeLast(nth interface{}, opts ...interface{}) *gomock.Call

TakeLast indicates an expected call of TakeLast.

func (*MockStreamMockRecorder) TakeUntil 

func (mr *MockStreamMockRecorder) TakeUntil(apply interface{}, opts ...interface{}) *gomock.Call

TakeUntil indicates an expected call of TakeUntil.

func (*MockStreamMockRecorder) TakeWhile 

func (mr *MockStreamMockRecorder) TakeWhile(apply interface{}, opts ...interface{}) *gomock.Call

TakeWhile indicates an expected call of TakeWhile.

func (*MockStreamMockRecorder) TimeInterval 

func (mr *MockStreamMockRecorder) TimeInterval(opts ...interface{}) *gomock.Call

TimeInterval indicates an expected call of TimeInterval.

func (*MockStreamMockRecorder) Timestamp 

func (mr *MockStreamMockRecorder) Timestamp(opts ...interface{}) *gomock.Call

Timestamp indicates an expected call of Timestamp.

func (*MockStreamMockRecorder) ToMap 

func (mr *MockStreamMockRecorder) ToMap(keySelector interface{}, opts ...interface{}) *gomock.Call

ToMap indicates an expected call of ToMap.

func (*MockStreamMockRecorder) ToMapWithValueSelector 

func (mr *MockStreamMockRecorder) ToMapWithValueSelector(keySelector, valueSelector interface{}, opts ...interface{}) *gomock.Call

ToMapWithValueSelector indicates an expected call of ToMapWithValueSelector.

func (*MockStreamMockRecorder) ToSlice 

func (mr *MockStreamMockRecorder) ToSlice(initialCapacity interface{}, opts ...interface{}) *gomock.Call

ToSlice indicates an expected call of ToSlice.

func (*MockStreamMockRecorder) Unmarshal 

func (mr *MockStreamMockRecorder) Unmarshal(unmarshaller, factory interface{}, opts ...interface{}) *gomock.Call

Unmarshal indicates an expected call of Unmarshal.

func (*MockStreamMockRecorder) WindowWithCount 

func (mr *MockStreamMockRecorder) WindowWithCount(count interface{}, opts ...interface{}) *gomock.Call

WindowWithCount indicates an expected call of WindowWithCount.

func (*MockStreamMockRecorder) WindowWithTime 

func (mr *MockStreamMockRecorder) WindowWithTime(milliseconds interface{}, opts ...interface{}) *gomock.Call

WindowWithTime indicates an expected call of WindowWithTime.

func (*MockStreamMockRecorder) WindowWithTimeOrCount 

func (mr *MockStreamMockRecorder) WindowWithTimeOrCount(milliseconds, count interface{}, opts ...interface{}) *gomock.Call

WindowWithTimeOrCount indicates an expected call of WindowWithTimeOrCount.

func (*MockStreamMockRecorder) ZipFromIterable 

func (mr *MockStreamMockRecorder) ZipFromIterable(iterable, zipper interface{}, opts ...interface{}) *gomock.Call

ZipFromIterable indicates an expected call of ZipFromIterable.

func (*MockStreamMockRecorder) ZipMultiObservers 

func (mr *MockStreamMockRecorder) ZipMultiObservers(observers, zipper interface{}) *gomock.Call

ZipMultiObservers indicates an expected call of ZipMultiObservers.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.