Skip to content

Commit 33a5b7e

Browse files
committed
Remove todos
1 parent d3c8148 commit 33a5b7e

File tree

2 files changed

+0
-3
lines changed

2 files changed

+0
-3
lines changed

factory.go

-2
Original file line numberDiff line numberDiff line change
@@ -227,8 +227,6 @@ func Interval(interval Duration, opts ...Option) Observable {
227227

228228
// Just creates an Observable with the provided items.
229229
func Just(items interface{}, opts ...Option) Observable {
230-
// TODO WithErrorStrategy?
231-
// TODO WithObservationStrategy?
232230
return &ObservableImpl{
233231
iterable: newJustIterable(items, opts...),
234232
}

observable_operator.go

-1
Original file line numberDiff line numberDiff line change
@@ -450,7 +450,6 @@ func (o *ObservableImpl) BufferWithTime(timespan Duration, opts ...Option) Obser
450450
return Thrown(IllegalInputError{error: "timespan must no be nil"})
451451
}
452452

453-
// TODO Handle eager observation
454453
return &ObservableImpl{
455454
iterable: newFactoryIterable(func(propagatedOptions ...Option) <-chan Item {
456455
mergedOptions := append(opts, propagatedOptions...)

0 commit comments

Comments
 (0)