没有合适的资源?快使用搜索试试~ 我知道了~
Reactive Streams in Java.pdf
需积分: 50 10 下载量 89 浏览量
2019-05-17
02:20:56
上传
评论
收藏 1.63MB PDF 举报
温馨提示
Reactive Streams in Java Concurrency with RxJava, Reactor, and Akka Streams. 2019年最新出版,清晰文字PDF,带目录书签。
资源推荐
资源详情
资源评论























Reactive Streams in Java: Concurrency with RxJava, Reactor,
and Akka Streams
ISBN-13 (pbk): 978-1-4842-4175-2 ISBN-13 (electronic): 978-1-4842-4176-9
https://doi.org/10.1007/978-1-4842-4176-9
Library of Congress Control Number: 2018965180
Copyright © 2019 by Adam L.Davis
is work is subject to copyright. All rights are reserved by the Publisher, whether the whole or
part of the material is concerned, specically the rights of translation, reprinting, reuse of
illustrations, recitation, broadcasting, reproduction on microlms or in any other physical way,
and transmission or information storage and retrieval, electronic adaptation, computer software,
or by similar or dissimilar methodology now known or hereafter developed.
Trademarked names, logos, and images may appear in this book. Rather than use a trademark
symbol with every occurrence of a trademarked name, logo, or image we use the names, logos,
and images only in an editorial fashion and to the benet of the trademark owner, with no
intention of infringement of the trademark.
e use in this publication of trade names, trademarks, service marks, and similar terms, even if
they are not identied as such, is not to be taken as an expression of opinion as to whether or not
they are subject to proprietary rights.
While the advice and information in this book are believed to be true and accurate at the date of
publication, neither the authors nor the editors nor the publisher can accept any legal
responsibility for any errors or omissions that may be made. e publisher makes no warranty,
express or implied, with respect to the material contained herein.
Managing Director, Apress Media LLC: Welmoed Spahr
Acquisitions Editor: Steve Anglin
Development Editor: Matthew Moodie
Coordinating Editor: Mark Powers
Cover designed by eStudioCalamar
Cover image designed by Freepik (www.freepik.com)
Distributed to the book trade worldwide by Springer Science+Business Media NewYork,
233 Spring Street, 6th Floor, NewYork, NY 10013. Phone 1-800-SPRINGER, fax (201) 348-4505,
e-mail orders-ny@springer-sbm.com, or visit www.springeronline.com. Apress Media, LLC is a
California LLC and the sole member (owner) is Springer Science + Business Media Finance Inc
(SSBM Finance Inc). SSBM Finance Inc is a Delaware corporation.
For information on translations, please e-mail editorial@apress.com; for reprint, paperback, or
audio rights, please email bookpermissions@springernature.com.
Apress titles may be purchased in bulk for academic, corporate, or promotional use. eBook
versions and licenses are also available for most titles. For more information, reference our Print
and eBook Bulk Sales web page at http://www.apress.com/bulk-sales.
Any source code or other supplementary material referenced by the author in this book is
available to readers on GitHub via the book's product page, located at www.apress.com/
9781484241752. For more detailed information, please visit http://www.apress.com/
source-code.
Printed on acid-free paper
AdamL.Davis
Oviedo, FL, USA
www.allitebooks.com

iii
Table of Contents
Chapter 1: Introduction to Reactive Streams ���������������������������������������1
Java 9+ �����������������������������������������������������������������������������������������������������������������2
Flow ����������������������������������������������������������������������������������������������������������������������2
Code for This Book ������������������������������������������������������������������������������������������������ 3
Chapter 2: Existing Models of Concurrency in Java �����������������������������5
Prominent Models for Concurrency�����������������������������������������������������������������������5
Synchronize in Java ����������������������������������������������������������������������������������������������6
Java Futures ���������������������������������������������������������������������������������������������������������6
Drawbacks of the Future Interface ������������������������������������������������������������������7
CompletableFuture ������������������������������������������������������������������������������������������7
STM in Clojure �����������������������������������������������������������������������������������������������������10
Actors ������������������������������������������������������������������������������������������������������������������11
Groovy GPars �������������������������������������������������������������������������������������������������������12
Reactive Streams ������������������������������������������������������������������������������������������������ 12
Chapter 3: Common Concepts ������������������������������������������������������������15
Streams ���������������������������������������������������������������������������������������������������������������15
Hot and Cold ��������������������������������������������������������������������������������������������������������15
Backpressure ������������������������������������������������������������������������������������������������������16
About the Author ���������������������������������������������������������������������������������ix
About the Technical Reviewer �������������������������������������������������������������xi
Preface ����������������������������������������������������������������������������������������������xiii
www.allitebooks.com

iv
Filter ��������������������������������������������������������������������������������������������������������������������16
Any/All �����������������������������������������������������������������������������������������������������������������17
Map ���������������������������������������������������������������������������������������������������������������������18
FlatMap/ConcatMap �������������������������������������������������������������������������������������������� 18
Delay �������������������������������������������������������������������������������������������������������������������19
Buffer ������������������������������������������������������������������������������������������������������������������19
Window ���������������������������������������������������������������������������������������������������������������20
Take While ����������������������������������������������������������������������������������������������������������� 21
Latest ������������������������������������������������������������������������������������������������������������������22
Debounce ������������������������������������������������������������������������������������������������������������22
Throttle First �������������������������������������������������������������������������������������������������������23
Chapter 4: RxJava�������������������������������������������������������������������������������25
Getting Started ���������������������������������������������������������������������������������������������������� 25
Flowable ��������������������������������������������������������������������������������������������������������������26
Parallel Computing ����������������������������������������������������������������������������������������������27
Schedulers ����������������������������������������������������������������������������������������������������������28
Publishers �����������������������������������������������������������������������������������������������������������30
Backpressure ������������������������������������������������������������������������������������������������������34
Handling Errors ���������������������������������������������������������������������������������������������������36
Testing �����������������������������������������������������������������������������������������������������������37
Chapter 5: Reactor ������������������������������������������������������������������������������41
Getting Started ���������������������������������������������������������������������������������������������������� 41
Flux ���������������������������������������������������������������������������������������������������������������������42
Mono �������������������������������������������������������������������������������������������������������������������43
Creating a Flux or Mono �������������������������������������������������������������������������������������� 44
Schedulers ����������������������������������������������������������������������������������������������������������46
Pull Events ����������������������������������������������������������������������������������������������������������49
Table of ConTenTsTable of ConTenTs
www.allitebooks.com
剩余145页未读,继续阅读
资源评论

- #完美解决问题
- #运行顺畅
- #内容详尽
- #全网独家
- #注释完整

no1hero
- 粉丝: 3
上传资源 快速赚钱
我的内容管理 展开
我的资源 快来上传第一个资源
我的收益
登录查看自己的收益我的积分 登录查看自己的积分
我的C币 登录后查看C币余额
我的收藏
我的下载
下载帮助


最新资源
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈



安全验证
文档复制为VIP权益,开通VIP直接复制
