<PackageReference Include="System.Reactive" Version="4.2.0-preview.63" />
SkipWhile<TSource>
namespace System.
Reactive.
Linq.
ObservableImpl
{
internal static class SkipWhile<
TSource>
{
internal sealed class Predicate :
Producer<
TSource,
Predicate.
_>
{
internal sealed class _ :
IdentitySink<
TSource>
{
private Func<
TSource,
bool>
_predicate;
public _(
Func<
TSource,
bool>
predicate,
IObserver<
TSource>
observer)
:
base(
observer)
{
_predicate =
predicate;
}
public override void OnNext(
TSource value)
{
if (
_predicate !=
null) {
bool flag =
false;
try {
flag = !
_predicate(
value);
}
catch (
Exception error) {
ForwardOnError(
error);
return;
}
if (
flag) {
_predicate =
null;
ForwardOnNext(
value);
}
}
else
ForwardOnNext(
value);
}
}
private readonly IObservable<
TSource>
_source;
private readonly Func<
TSource,
bool>
_predicate;
public Predicate(
IObservable<
TSource>
source,
Func<
TSource,
bool>
predicate)
{
_source =
source;
_predicate =
predicate;
}
protected override _ CreateSink(
IObserver<
TSource>
observer)
{
return new _(
_predicate,
observer);
}
protected override void Run(
_ sink)
{
sink.
Run(
_source);
}
}
internal sealed class PredicateIndexed :
Producer<
TSource,
PredicateIndexed.
_>
{
internal sealed class _ :
IdentitySink<
TSource>
{
private Func<
TSource,
int,
bool>
_predicate;
private int _index;
public _(
Func<
TSource,
int,
bool>
predicate,
IObserver<
TSource>
observer)
:
base(
observer)
{
_predicate =
predicate;
}
public override void OnNext(
TSource value)
{
if (
_predicate !=
null) {
bool flag =
false;
try {
flag = !
_predicate(
value,
checked(
_index++));
}
catch (
Exception error) {
ForwardOnError(
error);
return;
}
if (
flag) {
_predicate =
null;
ForwardOnNext(
value);
}
}
else
ForwardOnNext(
value);
}
}
private readonly IObservable<
TSource>
_source;
private readonly Func<
TSource,
int,
bool>
_predicate;
public PredicateIndexed(
IObservable<
TSource>
source,
Func<
TSource,
int,
bool>
predicate)
{
_source =
source;
_predicate =
predicate;
}
protected override _ CreateSink(
IObserver<
TSource>
observer)
{
return new _(
_predicate,
observer);
}
protected override void Run(
_ sink)
{
sink.
Run(
_source);
}
}
}
}