Java CoreSubscriber类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中reactor.core.CoreSubscriber类的典型用法代码示例。如果您正苦于以下问题：Java CoreSubscriber类的具体用法？Java CoreSubscriber怎么用？Java CoreSubscriber使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

CoreSubscriber类属于reactor.core包，在下文中一共展示了CoreSubscriber类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: subscribe

import reactor.core.CoreSubscriber; //导入依赖的package包/类
@Override
public final void subscribe(final CoreSubscriber<? super Void> s) {
	if(future.isDone()){
		if(future.isSuccess()){
			Operators.complete(s);
		}
		else{
			Operators.error(s, future.cause());
		}
		return;
	}

	FutureSubscription<F> fs = new FutureSubscription<>(future, s);
	s.onSubscribe(fs);
	future.addListener(fs);
}

开发者ID:reactor，项目名称:reactor-netty，代码行数:17，代码来源:FutureMono.java

示例2: scanThenAcceptInner

import reactor.core.CoreSubscriber; //导入依赖的package包/类
@Test
public void scanThenAcceptInner() {
	CoreSubscriber<String> actual = new LambdaMonoSubscriber<>(null, e -> {}, null, null);
	MonoIgnoreThen.ThenIgnoreMain<String> main = new MonoIgnoreThen.ThenIgnoreMain<>(actual, new Publisher[0], Mono.just("foo"));

	MonoIgnoreThen.ThenAcceptInner<String> test = new MonoIgnoreThen.ThenAcceptInner<>(main);
	Subscription parent = Operators.emptySubscription();
	test.onSubscribe(parent);

	assertThat(test.scan(Scannable.Attr.PARENT)).isSameAs(parent);
	assertThat(test.scan(Scannable.Attr.ACTUAL)).isSameAs(main);

	assertThat(test.scan(Scannable.Attr.TERMINATED)).isFalse();
	test.onError(new IllegalStateException("boom"));
	assertThat(test.scan(Scannable.Attr.TERMINATED)).isTrue();

	assertThat(test.scan(Scannable.Attr.CANCELLED)).isFalse();
	test.cancel();
	assertThat(test.scan(Scannable.Attr.CANCELLED)).isTrue();
}

开发者ID:reactor，项目名称:reactor-core，代码行数:21，代码来源:MonoThenIgnoreTest.java

示例3: scanInner

import reactor.core.CoreSubscriber; //导入依赖的package包/类
@Test
public void scanInner() {
    CoreSubscriber<String> actual = new LambdaSubscriber<>(null, e -> {}, null, null);
    FluxFilterWhen.FluxFilterWhenSubscriber<String> main = new FluxFilterWhen.FluxFilterWhenSubscriber<>(actual, t -> Mono.just(true), 789);

    FluxFilterWhen.FilterWhenInner test = new FluxFilterWhen.FilterWhenInner(main, true);
    Subscription sub = Operators.emptySubscription();
    test.onSubscribe(sub);

    assertThat(test.scan(Scannable.Attr.PREFETCH)).isEqualTo(Integer.MAX_VALUE);
    assertThat(test.scan(Scannable.Attr.PARENT)).isSameAs(main);
    assertThat(test.scan(Scannable.Attr.ACTUAL)).isSameAs(sub);
    assertThat(test.scan(Scannable.Attr.REQUESTED_FROM_DOWNSTREAM)).isEqualTo(1L);

    assertThat(test.scan(Scannable.Attr.TERMINATED)).isFalse();
    test.onNext(false);
    assertThat(test.scan(Scannable.Attr.TERMINATED)).isTrue();
    assertThat(test.scan(Scannable.Attr.REQUESTED_FROM_DOWNSTREAM)).isEqualTo(0L);

    assertThat(test.scan(Scannable.Attr.CANCELLED)).isFalse();
    test.cancel();
    assertThat(test.scan(Scannable.Attr.CANCELLED)).isTrue();
}

开发者ID:reactor，项目名称:reactor-core，代码行数:24，代码来源:FluxFilterWhenTest.java

示例4: scanPostOnSubscribeSubscriber

import reactor.core.CoreSubscriber; //导入依赖的package包/类
@Test
public void scanPostOnSubscribeSubscriber() {
	CoreSubscriber<String> s = new LambdaSubscriber<>(null, null, null, null);
	StrictSubscriber<String> test = new StrictSubscriber<>(s);

	assertThat(test.scan(Scannable.Attr.ACTUAL)).isSameAs(s);
	assertThat(test.scan(Scannable.Attr.PARENT)).isNull();
	assertThat(test.scan(Scannable.Attr.CANCELLED)).isFalse();
	assertThat(test.scan(Scannable.Attr.REQUESTED_FROM_DOWNSTREAM)).isEqualTo(0L);

	test.request(2);
	assertThat(test.scan(Scannable.Attr.REQUESTED_FROM_DOWNSTREAM)).isEqualTo(2L);

	Subscription parent = Operators.cancelledSubscription();
	test.onSubscribe(parent);
	assertThat(test.scan(Scannable.Attr.PARENT)).isSameAs(parent);
	assertThat(test.scan(Scannable.Attr.CANCELLED)).isTrue();
}

开发者ID:reactor，项目名称:reactor-core，代码行数:19，代码来源:StrictSubscriberTest.java

示例5: subscribe

import reactor.core.CoreSubscriber; //导入依赖的package包/类
@Override
public void subscribe(CoreSubscriber<? super R> actual) {

	JoinSubscription<TLeft, TRight, TLeftEnd, TRightEnd, R> parent =
			new JoinSubscription<>(actual,
					leftEnd,
					rightEnd,
					resultSelector,
					queueSupplier.get());

	actual.onSubscribe(parent);

	LeftRightSubscriber left = new LeftRightSubscriber(parent, true);
	parent.cancellations.add(left);
	LeftRightSubscriber right = new LeftRightSubscriber(parent, false);
	parent.cancellations.add(right);

	source.subscribe(left);
	other.subscribe(right);
}

开发者ID:reactor，项目名称:reactor-core，代码行数:21，代码来源:FluxJoin.java

示例6: scanSubscriberCancelled

import reactor.core.CoreSubscriber; //导入依赖的package包/类
@Test
public void scanSubscriberCancelled() {
	CoreSubscriber<String> actual = new LambdaSubscriber<>(null, e -> {}, null, null);
	FluxDetach.DetachSubscriber<String> test = new FluxDetach.DetachSubscriber<>(actual);
	Subscription parent = Operators.emptySubscription();
	test.onSubscribe(parent);

	assertThat(test.scan(Scannable.Attr.PARENT)).isSameAs(parent);
	assertThat(test.scan(Scannable.Attr.ACTUAL)).isSameAs(actual);
	assertThat(test.scan(Scannable.Attr.TERMINATED)).isFalse();
	assertThat(test.scan(Scannable.Attr.CANCELLED)).isFalse();

	test.cancel();
	assertThat(test.scan(Scannable.Attr.PARENT)).isNull();
	assertThat(test.scan(Scannable.Attr.ACTUAL)).isNull();
	assertThat(test.scan(Scannable.Attr.CANCELLED)).isTrue();
	assertThat(test.scan(Scannable.Attr.TERMINATED)).isTrue();
}

开发者ID:reactor，项目名称:reactor-core，代码行数:19，代码来源:FluxDetachTest.java

示例7: scanOtherSubscriber

import reactor.core.CoreSubscriber; //导入依赖的package包/类
@Test
public void scanOtherSubscriber() {
	CoreSubscriber<String> actual = new LambdaSubscriber<>(null, e -> {}, null,
			sub -> sub.request(100));
	FluxDelaySubscription.DelaySubscriptionOtherSubscriber<String, Integer> test = new FluxDelaySubscription.DelaySubscriptionOtherSubscriber<String, Integer>(
			actual, s -> {});
	Subscription parent = Operators.emptySubscription();
	test.onSubscribe(parent);

	assertThat(test.scan(Scannable.Attr.REQUESTED_FROM_DOWNSTREAM)).isEqualTo(100L);

	assertThat(test.scan(Scannable.Attr.PARENT)).isSameAs(parent);
	assertThat(test.scan(Scannable.Attr.ACTUAL)).isSameAs(actual);

	assertThat(test.scan(Scannable.Attr.CANCELLED)).isFalse();
	assertThat(test.scan(Scannable.Attr.TERMINATED)).isFalse();

	test.onError(new IllegalStateException("boom"));
	assertThat(test.scan(Scannable.Attr.CANCELLED)).isFalse();
	assertThat(test.scan(Scannable.Attr.TERMINATED)).isTrue();

	test.cancel();
	assertThat(test.scan(Scannable.Attr.CANCELLED)).isTrue();
}

开发者ID:reactor，项目名称:reactor-core，代码行数:25，代码来源:FluxDelaySubscriptionTest.java

示例8: scanHasElements

import reactor.core.CoreSubscriber; //导入依赖的package包/类
@Test
public void scanHasElements() {
	CoreSubscriber<? super Boolean> actual = new LambdaMonoSubscriber<>(null, e -> {}, null, null);
	MonoHasElements.HasElementsSubscriber<String> test = new MonoHasElements.HasElementsSubscriber<>(actual);
	Subscription parent = Operators.emptySubscription();
	test.onSubscribe(parent);

	assertThat(test.scan(Scannable.Attr.PARENT)).isSameAs(parent);
	assertThat(test.scan(Scannable.Attr.ACTUAL)).isSameAs(actual);
	assertThat(test.scan(Scannable.Attr.PREFETCH)).isEqualTo(Integer.MAX_VALUE);

	assertThat(test.scan(Scannable.Attr.TERMINATED)).isFalse();
	assertThat(test.scan(Scannable.Attr.CANCELLED)).isFalse();

	test.onComplete();
	assertThat(test.scan(Scannable.Attr.TERMINATED)).isTrue();
	assertThat(test.scan(Scannable.Attr.CANCELLED)).isFalse();
}

开发者ID:reactor，项目名称:reactor-core，代码行数:19，代码来源:MonoHasElementsTest.java

示例9: scanMultiSubscriptionSubscriber

import reactor.core.CoreSubscriber; //导入依赖的package包/类
@Test
public void scanMultiSubscriptionSubscriber() {
	CoreSubscriber<Integer> actual = new LambdaSubscriber<>(null, null, null, null);
	MultiSubscriptionSubscriber<Integer, Integer> test = new MultiSubscriptionSubscriber<Integer, Integer>(actual) {
		@Override
		public void onNext(Integer t) {
		}
	};
	Subscription parent = Operators.emptySubscription();
       test.onSubscribe(parent);
	Assertions.assertThat(test.scan(Scannable.Attr.ACTUAL)).isSameAs(actual);
	Assertions.assertThat(test.scan(Scannable.Attr.PARENT)).isSameAs(parent);
	test.request(34);
	Assertions.assertThat(test.scan(Scannable.Attr.REQUESTED_FROM_DOWNSTREAM)).isEqualTo(34);

	Assertions.assertThat(test.scan(Scannable.Attr.CANCELLED)).isFalse();
	test.cancel();
	Assertions.assertThat(test.scan(Scannable.Attr.CANCELLED)).isTrue();
}

开发者ID:reactor，项目名称:reactor-core，代码行数:20，代码来源:OperatorsTest.java

示例10: scanSubscriber

import reactor.core.CoreSubscriber; //导入依赖的package包/类
@Test
public void scanSubscriber() {
	CoreSubscriber<Boolean> actual = new LambdaMonoSubscriber<>(null, e -> {}, null, null);
	MonoAny.AnySubscriber<String> test = new MonoAny.AnySubscriber<>(actual, String::isEmpty);
	Subscription parent = Operators.emptySubscription();
	test.onSubscribe(parent);

	assertThat(test.scan(Scannable.Attr.PREFETCH)).isEqualTo(Integer.MAX_VALUE);

	assertThat(test.scan(Scannable.Attr.PARENT)).isSameAs(parent);
	assertThat(test.scan(Scannable.Attr.ACTUAL)).isSameAs(actual);


	assertThat(test.scan(Scannable.Attr.TERMINATED)).isFalse();
	test.onError(new IllegalStateException("boom"));
	assertThat(test.scan(Scannable.Attr.TERMINATED)).isTrue();

	assertThat(test.scan(Scannable.Attr.CANCELLED)).isFalse();
	test.cancel();
	assertThat(test.scan(Scannable.Attr.CANCELLED)).isTrue();
}

开发者ID:reactor，项目名称:reactor-core，代码行数:22，代码来源:MonoAnyTest.java

示例11: scanMulticastInner

import reactor.core.CoreSubscriber; //导入依赖的package包/类
@Test
  public void scanMulticastInner() {
CoreSubscriber<Integer> actual = new LambdaSubscriber<>(null, e -> {}, null, null);
FluxPublishMulticast.FluxPublishMulticaster<Integer> parent =
      		new FluxPublishMulticast.FluxPublishMulticaster<>(123, Queues.<Integer>unbounded(), Context.empty());
      FluxPublishMulticast.PublishMulticastInner<Integer> test =
      		new FluxPublishMulticast.PublishMulticastInner<>(parent, actual);

      assertThat(test.scan(Scannable.Attr.PARENT)).isSameAs(parent);
      assertThat(test.scan(Scannable.Attr.ACTUAL)).isSameAs(actual);
      test.request(789);
      assertThat(test.scan(Scannable.Attr.REQUESTED_FROM_DOWNSTREAM)).isEqualTo(789);

      assertThat(test.scan(Scannable.Attr.CANCELLED)).isFalse();
      test.cancel();
      assertThat(test.scan(Scannable.Attr.CANCELLED)).isTrue();
  }

开发者ID:reactor，项目名称:reactor-core，代码行数:18，代码来源:FluxPublishMulticastTest.java

示例12: subscribe

import reactor.core.CoreSubscriber; //导入依赖的package包/类
@Override
public void subscribe(CoreSubscriber<? super T> actual) {
	Objects.requireNonNull(actual, "subscribe");
	if (once == 0 && ONCE.compareAndSet(this, 0, 1)) {

		actual.onSubscribe(this);
		this.actual = actual;
		if (cancelled) {
			this.actual = null;
		} else {
			drain();
		}
	} else {
		Operators.error(actual, new IllegalStateException("UnicastProcessor " +
				"allows only a single Subscriber"));
	}
}

开发者ID:reactor，项目名称:reactor-core，代码行数:18，代码来源:UnicastProcessor.java

示例13: subscribe

import reactor.core.CoreSubscriber; //导入依赖的package包/类
@Override
@SuppressWarnings("unchecked")
public void subscribe(CoreSubscriber<? super T> actual) {
	Publisher<? extends T> p;

	try {
		p = Objects.requireNonNull(supplier.get(),
				"The Publisher returned by the supplier is null");
	}
	catch (Throwable e) {
		Operators.error(actual, Operators.onOperatorError(e, actual.currentContext()));
		return;
	}

	from(p).subscribe(actual);
}

开发者ID:reactor，项目名称:reactor-core，代码行数:17，代码来源:FluxDefer.java

示例14: scanMain

import reactor.core.CoreSubscriber; //导入依赖的package包/类
@Test
public void scanMain() {
	CoreSubscriber<? super List> actual = new LambdaSubscriber<>(null, e -> {}, null, null);
	List<String> initialBuffer = Arrays.asList("foo", "bar");
	FluxBufferBoundary.BufferBoundaryMain<String, Integer, List<String>> test = new FluxBufferBoundary.BufferBoundaryMain<>(
			actual, initialBuffer, ArrayList::new);
	Subscription parent = Operators.cancelledSubscription();
	test.onSubscribe(parent);

	assertThat(test.scan(Scannable.Attr.CAPACITY)).isEqualTo(2);
	assertThat(test.scan(Scannable.Attr.PREFETCH)).isEqualTo(Integer.MAX_VALUE);

	assertThat(test.scan(Scannable.Attr.REQUESTED_FROM_DOWNSTREAM)).isEqualTo(0L);
	test.request(2);
	assertThat(test.scan(Scannable.Attr.REQUESTED_FROM_DOWNSTREAM)).isEqualTo(2L);

	assertThat(test.scan(Scannable.Attr.PARENT)).isSameAs(parent);
	assertThat(test.scan(Scannable.Attr.ACTUAL)).isSameAs(actual);

	assertThat(test.scan(Scannable.Attr.CANCELLED)).isTrue();
}

开发者ID:reactor，项目名称:reactor-core，代码行数:22，代码来源:FluxBufferBoundaryTest.java

示例15: scanSubscriber

import reactor.core.CoreSubscriber; //导入依赖的package包/类
@Test
public void scanSubscriber() {
    CoreSubscriber<Integer> actual = new LambdaSubscriber<>(null, e -> {}, null, null);
    FluxPeek<Integer> peek = new FluxPeek<>(Flux.just(1), s -> {}, s -> {},
    		e -> {}, () -> {}, () -> {}, r -> {}, () -> {});
    FluxPeek.PeekSubscriber<Integer> test = new FluxPeek.PeekSubscriber<>(actual, peek);
    Subscription parent = Operators.emptySubscription();
    test.onSubscribe(parent);

    Assertions.assertThat(test.scan(Scannable.Attr.PARENT)).isSameAs(parent);
    Assertions.assertThat(test.scan(Scannable.Attr.ACTUAL)).isSameAs(actual);

    Assertions.assertThat(test.scan(Scannable.Attr.TERMINATED)).isFalse();
    test.onError(new IllegalStateException("boom"));
    Assertions.assertThat(test.scan(Scannable.Attr.TERMINATED)).isTrue();
}

开发者ID:reactor，项目名称:reactor-core，代码行数:17，代码来源:FluxPeekTest.java

示例16: scanTakeLastOneSubscriber

import reactor.core.CoreSubscriber; //导入依赖的package包/类
@Test
public void scanTakeLastOneSubscriber() {
	CoreSubscriber<String>
			actual = new LambdaMonoSubscriber<>(null, e -> {}, null, null);
	MonoTakeLastOne.TakeLastOneSubscriber<String> test = new MonoTakeLastOne.TakeLastOneSubscriber<>(
			actual, "foo", true);
	Subscription parent = Operators.emptySubscription();
	test.onSubscribe(parent);

	assertThat(test.scan(Scannable.Attr.PREFETCH)).isEqualTo(Integer.MAX_VALUE);

	assertThat(test.scan(Scannable.Attr.PARENT)).isSameAs(parent);
	assertThat(test.scan(Scannable.Attr.ACTUAL)).isSameAs(actual);

	//terminated is detected via state HAS_VALUE
	assertThat(test.scan(Scannable.Attr.TERMINATED)).isFalse();
	test.complete("bar");
	assertThat(test.scan(Scannable.Attr.TERMINATED)).isTrue();

	assertThat(test.scan(Scannable.Attr.CANCELLED)).isFalse();
	test.cancel();
	assertThat(test.scan(Scannable.Attr.CANCELLED)).isTrue();
}

开发者ID:reactor，项目名称:reactor-core，代码行数:24，代码来源:MonoTakeLastOneTest.java

示例17: scanCoordinator

import reactor.core.CoreSubscriber; //导入依赖的package包/类
@Test
  public void scanCoordinator() {
CoreSubscriber<Integer> actual = new LambdaSubscriber<>(null, e -> {}, null, null);
FluxZip.ZipCoordinator<Integer, Integer> test = new FluxZip.ZipCoordinator<Integer, Integer>(actual,
		i -> 5, 123, Queues.unbounded(), 345);

      Assertions.assertThat(test.scan(Scannable.Attr.ACTUAL)).isSameAs(actual);
      test.requested = 35;
      Assertions.assertThat(test.scan(Scannable.Attr.REQUESTED_FROM_DOWNSTREAM)).isEqualTo(35);

      Assertions.assertThat(test.scan(Scannable.Attr.ERROR)).isNull();
      test.error = new IllegalStateException("boom");
      Assertions.assertThat(test.scan(Scannable.Attr.ERROR)).hasMessage("boom");

      Assertions.assertThat(test.scan(Scannable.Attr.CANCELLED)).isFalse();
      test.cancel();
      Assertions.assertThat(test.scan(Scannable.Attr.CANCELLED)).isTrue();
  }

开发者ID:reactor，项目名称:reactor-core，代码行数:19，代码来源:FluxZipTest.java

示例18: subscribe

import reactor.core.CoreSubscriber; //导入依赖的package包/类
@Override
public void subscribe(CoreSubscriber<? super C> actual) {
	C initialBuffer;

	try {
		initialBuffer = Objects.requireNonNull(bufferSupplier.get(),
				"The bufferSupplier returned a null initial buffer");
	}
	catch (Throwable e) {
		Operators.error(actual, Operators.onOperatorError(e, actual.currentContext()));
		return;
	}

	BufferPredicateSubscriber<T, C> parent = new BufferPredicateSubscriber<>(actual,
			initialBuffer, bufferSupplier, predicate, mode);

	source.subscribe(parent);
}

开发者ID:reactor，项目名称:reactor-core，代码行数:19，代码来源:FluxBufferPredicate.java

示例19: scanMainSubscriber

import reactor.core.CoreSubscriber; //导入依赖的package包/类
@Test
public void scanMainSubscriber() {
	CoreSubscriber<? super Integer> subscriber = new LambdaSubscriber<>(null, e -> { }, null,
			sub -> sub.request(2));
	MergeReduceMain<Integer> test = new MergeReduceMain<>(subscriber, 2, (a, b) -> a + b);

	subscriber.onSubscribe(test);

	assertThat(test.scan(Scannable.Attr.ACTUAL)).isSameAs(subscriber);
	assertThat(test.scan(Scannable.Attr.PREFETCH)).isEqualTo(Integer.MAX_VALUE);

	assertThat(test.scan(Scannable.Attr.TERMINATED)).isFalse();
	assertThat(test.scan(Scannable.Attr.ERROR)).isNull();

	test.innerComplete(1);
	test.innerComplete(2);
	assertThat(test.scan(Scannable.Attr.TERMINATED)).isTrue();

	assertThat(test.scan(Scannable.Attr.CANCELLED)).isFalse();
	test.cancel();
	assertThat(test.scan(Scannable.Attr.CANCELLED)).isTrue();
}

开发者ID:reactor，项目名称:reactor-core，代码行数:23，代码来源:ParallelMergeReduceTest.java

示例20: scanInner

import reactor.core.CoreSubscriber; //导入依赖的package包/类
@Test
public void scanInner() {
	CoreSubscriber<String> actual = new LambdaSubscriber<>(null, null, null, null);
	FluxLimitRequest.FluxLimitRequestSubscriber<String> inner =
			new FluxLimitRequest.FluxLimitRequestSubscriber<>(actual, 2);
	Subscription s = Operators.emptySubscription();
	inner.onSubscribe(s);

	assertThat(inner.scan(Scannable.Attr.ACTUAL)).isSameAs(actual);
	assertThat(inner.scan(Scannable.Attr.PARENT)).isSameAs(s);
	assertThat(inner.scan(Scannable.Attr.TERMINATED)).isFalse();

	inner.onNext("foo");
	inner.onNext("bar");
	assertThat(inner.scan(Scannable.Attr.TERMINATED)).isTrue();
}

开发者ID:reactor，项目名称:reactor-core，代码行数:17，代码来源:FluxLimitRequestTest.java

注：本文中的reactor.core.CoreSubscriber类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java SendMessageToWeiboRequest类代码示例发布时间：2022-05-22

Java Word类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18290|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9682|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8181|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8552|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8461|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9397|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8432|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7867|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8416|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7394|2022-11-06

客服电话

电子邮件

Java CoreSubscriber类代码示例

示例1: subscribe

示例2: scanThenAcceptInner

示例3: scanInner

示例4: scanPostOnSubscribeSubscriber

示例5: subscribe

示例6: scanSubscriberCancelled

示例7: scanOtherSubscriber

示例8: scanHasElements

示例9: scanMultiSubscriptionSubscriber

示例10: scanSubscriber

示例11: scanMulticastInner

示例12: subscribe

示例13: subscribe

示例14: scanMain

示例15: scanSubscriber

示例16: scanTakeLastOneSubscriber

示例17: scanCoordinator

示例18: subscribe

示例19: scanMainSubscriber

示例20: scanInner

请发表评论

全部评论

上一篇：

下一篇：

PacktPublishing/Python-Machine-Learning-

sussillo/hfopt-matlab: A parallel, cpu-b

鲁东大学一米网:Win7系统USB驱动器RAM的操

CVE-2022-34571

emersion/go-ostatus: An OStatus library

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053