Skip to content

Commit 58b334f

Browse files
committed
Renamed method to match jvm
1 parent c510b2a commit 58b334f

File tree

5 files changed

+8
-8
lines changed

5 files changed

+8
-8
lines changed

src/tck/Reactive.Streams.TCK.Tests/IdentityProcessorVerificationTest.cs

+2-2
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,7 @@ public Spec104WaitingVerification(TestEnvironment environment, long publisherRef
9393

9494
public override IProcessor<int, int> CreateIdentityProcessor(int bufferSize) => new Processor();
9595

96-
public override IPublisher<int> CreateHelpPublisher(long elements) => new Publisher();
96+
public override IPublisher<int> CreateHelperPublisher(long elements) => new Publisher();
9797

9898
public override IPublisher<int> CreateFailedPublisher() => null;
9999
}
@@ -129,7 +129,7 @@ public Spec104IgnoreVerification(TestEnvironment environment) : base(environment
129129

130130
public override IPublisher<int> CreateFailedPublisher() => null;
131131

132-
public override IPublisher<int> CreateHelpPublisher(long elements) => null;
132+
public override IPublisher<int> CreateHelperPublisher(long elements) => null;
133133

134134
// can only support 1 subscribe => unable to run this test
135135
public override long MaxSupportedSubscribers { get; } = 1;

src/tck/Reactive.Streams.TCK/IdentityProcessorVerification.cs

+3-3
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,7 @@ public IdentifierWhiteboxVerification(IdentityProcessorVerification<T> processor
9393
public override ISubscriber<T> CreateSubscriber(WhiteboxSubscriberProbe<T> probe)
9494
=> _processor.CreateSubscriber(probe);
9595

96-
public override IPublisher<T> CreateHelpPublisher(long elements) => _processor.CreateHelpPublisher(elements);
96+
public override IPublisher<T> CreateHelperPublisher(long elements) => _processor.CreateHelperPublisher(elements);
9797
}
9898

9999
/// <summary>
@@ -166,7 +166,7 @@ public void SetUp()
166166
public IPublisher<T> CreatePublisher(long elements)
167167
{
168168
var processor = CreateIdentityProcessor(_processorBufferSize);
169-
var publisher = CreateHelpPublisher(elements);
169+
var publisher = CreateHelperPublisher(elements);
170170
publisher.Subscribe(processor);
171171
return processor; // we run the PublisherVerification against this
172172
}
@@ -595,7 +595,7 @@ public TestSetup(TestEnvironment environment, int testBufferSize, long requiredS
595595
TestBufferSize = testBufferSize;
596596
RequiredSubscribersSupport = requiredSubscribersSupport;
597597

598-
Tees = Environment.NewManualSubscriber(verification.CreateHelpPublisher(long.MaxValue));
598+
Tees = Environment.NewManualSubscriber(verification.CreateHelperPublisher(long.MaxValue));
599599
Processor = verification.CreateIdentityProcessor(testBufferSize);
600600
Subscribe(Processor);
601601
}

src/tck/Reactive.Streams.TCK/SubscriberBlackboxVerification.cs

+1-1
Original file line numberDiff line numberDiff line change
@@ -445,7 +445,7 @@ public BlackBoxTestStage(TestEnvironment environment, SubscriberBlackboxVerifica
445445

446446
public ISubscriber<T> Sub => Subscriber.Value;
447447

448-
public IPublisher<T> CreateHelperPublisher(long elements) => _verification.CreateHelpPublisher(elements);
448+
public IPublisher<T> CreateHelperPublisher(long elements) => _verification.CreateHelperPublisher(elements);
449449

450450
public BlackboxSubscriberProxy<T> CreateBlackboxSubscriberProxy(TestEnvironment environment, ISubscriber<T> subscriber)
451451
=> new BlackboxSubscriberProxy<T>(environment, subscriber);

src/tck/Reactive.Streams.TCK/SubscriberWhiteboxVerification.cs

+1-1
Original file line numberDiff line numberDiff line change
@@ -487,7 +487,7 @@ public WhiteboxTestStage(TestEnvironment environment, SubscriberWhiteboxVerifica
487487

488488
public ISubscriberPuppet Puppet => Probe.SubscriberPuppet;
489489

490-
public IPublisher<T> CreateHelperPublisher(long elements) => _verification.CreateHelpPublisher(elements);
490+
public IPublisher<T> CreateHelperPublisher(long elements) => _verification.CreateHelperPublisher(elements);
491491

492492
public WhiteboxSubscriberProbe<T> CreateWhiteboxSubscriberProbe(TestEnvironment environment)
493493
=> new WhiteboxSubscriberProbe<T>(environment, Subscriber);

src/tck/Reactive.Streams.TCK/WithHelperPublisher.cs

+1-1
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ public abstract class WithHelperPublisher<T>
4646
/// </summary>
4747
/// <param name="elements"></param>
4848
/// <returns></returns>
49-
public virtual IPublisher<T> CreateHelpPublisher(long elements)
49+
public virtual IPublisher<T> CreateHelperPublisher(long elements)
5050
=> elements > int.MaxValue
5151
? (IPublisher<T>) new InfiniteHelperPublisher<T>(CreateElement)
5252
: new HelperPublisher<T>(0, (int) elements, CreateElement);

0 commit comments

Comments
 (0)