没有合适的资源?快使用搜索试试~ 我知道了~
首页Reactive Streams in Java
资源详情
资源评论
资源推荐

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页未读,继续阅读
















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

评论0