Index

Search in book...
Toggle Font Controls
Create new playlist

Name your new playlist

Playlist description (optional)
Sign In

Email address

Password

Forgot Password?

or

Continue with Facebook

Continue with Google
Sign Up

Full Name

Email address

Confirm Email Address

Password

or

Continue with Facebook

Continue with Google

Previous Chapter

Catalog of Rx operators

List of Figures

Index

[A][B][C][D][E][F][G][H][I][J][K][L][M][N][O][P][Q][R][S][T][U][V][W][X][Y][Z]

A

absolute time Action delegate type Add method addHandler parameter, 2^nd Aggregate function, writing aggregation logic with All operator Amb operator anonymous methods closures (captured variables) and overview AnonymousObservable Any operator APM (Asynchronous Programming Model) pattern AsDisposable method AsObservable operator AssertEqual async-await pattern overview, 2^nd using in observable creation asynchronicity overview, 2^nd resource use and asynchronous approach asynchronous code creating tasks simplifying with async-await TAP pattern writing asynchronous execution asynchronous message passing asynchronous observable, not passing AsyncMethodCaller method AsyncSubject AutoDetachObserver wrapper Average operator awaiter, 2^nd

B

backpressure mitigating lossless approach lossy approach observables of different rates backstack BehaviorSubject, preserving latest state with BooleanDisposable class, 2^nd Buffer method buffering breaks

C

C# programming language advantages of concise code declarative programming style first-class functions immutability first-class functions, 2^nd using Action using anonymous methods using delegates using Func, 2nd using lambda expressions higher-order functions, 2^nd using Action using anonymous methods using delegates using Func, 2nd using lambda expressions method chaining fluent interfaces and with extension methods querying collections with LINQ anonymous types deferred execution joins LINQ operators nested queries overview caching sequence, with ReplaySubject CancellationDisposable class, 2^nd, 3^rd CancellationToken, 2^nd CancellationTokenSource, 2^nd captured variables catch block Catch operator, 2^nd CEP (complex event processing) ChatClient class, 2^nd ChatRoom Click event client-side technology Closed event closures CLR (Common Language Runtime) code, organizing cold observable, 2^nd, 3^rd CollectionExtensions collections combinators CombineLatest operator, 2^nd, 3^rd combining observables combining latest emitted values concatenating observables dynamic concatenating and merging merging observables pairing items from observables (zipping) switching to next observable combining operations Common Language Runtime. See CLR. complex event processing. See CEP. composability, in .NET events CompositeDisposable class, 2^nd composition Concat operator, 2^nd, 3^rd, 4^th, 5^th, 6^th, 7^th concatenating observables concurrency immutability and in .NET events in event-processing flow parameterizing ConcurrentDictionary Connect method, 2^nd, 3^rd, 4^th ConnectableObservable wrapper overview performing automatic disconnection reconnecting Contains operator ContextDisposable class, 2^nd ContinueWith method conversion function correlation group Count operator CPU-based operation Create method, 2^nd, 3^rd, 4^th CreateColdObservable method CreateHotObservable method CurrentThreadScheduler, 2^nd

D

data at rest data in motion data transfer object. See DTO. data-driven test DateTime property DateTimeOffset DateTimeOffset.UtcNow DDoS (distributed denial of service) declarative programming declarative query syntax Defer operator, 2^nd, 3^rd, 4^th DeferAsync deferred execution Delay operator, 2^nd, 3^rd, 4^th DelaySubscription operator delegates dictionaries, converting observable to Disposable.Create method Disposable.Empty property, 2^nd disposables library, Rx BooleanDisposable class CancellationDisposable class CompositeDisposable class ContextDisposable class Disposable.Create method Disposable.Empty property MultipleAssignmentDisposable class RefCountDisposable class ScheduledDisposable class SerialDisposable class SingleAssignmentDisposable class Dispose method, 2^nd, 3^rd, 4^th, 5^th, 6^th, 7^th, 8^th, 9^th distance variable Distinct operator, 2^nd, 3^rd, 4^th DistinctUntilChanged operator, 2^nd distributed denial of service. See DDoS. divide-and-conquer approach Do operator dotnet restore command drasticChanges variable dropped values DRY (Don’t Repeat Yourself) principle DSL (domain-specific language) DSP (digital signal processing) DTO (data transfer object) duality principle duration selector functions dynamic concatenating and merging dynamic windows

E

EAP (Event-Based Asynchronous Pattern) elasticity, in reactive programming electric eel logo elementSelector empty observables, creating empty parentheses enumerables converting observables to converting to observables flattening observables converting observable to dictionary converting observable to lookup EqualityComparer, 2^nd Error event error handling and recovery backpressure mitigating observables of different rates controlling lifetime of resources dangling observers deterministic finalization disposing in deterministic way reacting to errors catching errors errors from observable side retrying to subscribe in case of error error hiding event handler event source Event-Based Asynchronous Pattern. See EAP. event-processing flow, writing, 2^nd cleaning resources dealing with concurrency finding difference between ticks grouping stocks by symbol keeping code close performing synchronization providing improved resource handling subscribing to event using composable operators EventArgs class overview unwrapping eventargs type EventHandler event EventLoopScheduler, 2^nd, 3^rd EventPattern, creating observables that conform to events creating observables from creating observables that conform to EventPattern events that aren’t following event pattern events that have no arguments events with multiple parameters creating with observables creating observables with Observable.Create deferring observable creation implementing IObservable interface ObservableBase problem with handcrafted observables subscribing to Except operator exception swallowing extension methods extending type behavior with with method chaining Extensions

F

fake observable Filter operator, 2^nd FilterBursts operator, 2^nd, 3^rd filtering observables creating distinct sequence removing duplicate contiguous values with Where operator filters Finally operator, 2^nd First operator first-class functions, 2^nd using Action using anonymous methods using delegates using Func, 2^nd using lambda expressions FirstOrDefault operator flat stream, joining observables to FlatMap operator flattening enumerables messages observables fluent interfaces, method chaining and FluentAssertions library ForEach method, 2^nd from statements FromEvent method, 2^nd FromEventPattern method, 2^nd, 3^rd FRP (functional reactive programming) Func delegate type as factory overview functional programming

G

gate GC (garbage collection) Generate method, 2^nd GeneratePrimes method GetAwaiter method GetDiscounts method GetEnumerator parameter GetPageAsync method GoF (Gang of Four) Google Finance GroupBy operator, 2^nd, 3^rd grouping elements from observable GroupJoin operator overview, 2^nd with query syntax groups, joining observables into

H

heating observables higher-order functions, 2^nd, 3^rd using Action using anonymous methods using delegates using Func, 2^nd using lambda expressions hopping windows, 2^nd hot observable, 2^nd, 3^rd, 4^th

I

I/O-based operation IAsyncAction IAsyncOperationWithProgress IAsyncResult object IComparer interface IConcurrencyProvider IConnectableObservable interface IDisposable interface, 2^nd, 3^rd, 4^th, 5^th, 6^th IEnumerable interface, 2^nd, 3^rd, 4^th Immediate Message ImmediateScheduler immutability concurrency and side effects and imperative style Intersect operator Interval operator, 2^nd, 3^rd, 4^th IObservable interface implementing overview, 2^nd, 3^rd, 4^th IObserver interface, 2^nd, 3^rd, 4^th IQueryable IScheduler interface, 2^nd, 3^rd, 4^th ISchedulerLongRunning ISchedulerPeriodic IsCompleted property IsNullOrEmpty IsPrimeAsync method, 2^nd IStrategy interface ISubject interface

J

Join operator, 2^nd, 3^rd joining observables into groups to flat stream joins

K

keySelector function, 2^nd, 3^rd

L

lambda expressions Lazy class lazy loading Let keyword LINQ (Language Integrated Query) operators querying collections with anonymous types deferred execution joins nested queries operators overview Log operator, 2^nd LogWithThread operator LOH (Large Object Heap)

M

magic strings Map operator mapping marble diagrams Max operator Merge operator, 2^nd, 3^rd merging observables message-driven approach, with reactive programming method chaining fluent interfaces and with extension methods creating language extending type behavior Microsoft Band Microsoft.Reactive.Testing package, 2^nd, 3^rd Min operator MoveNext method mscorlib assembly MSTest Multicast operator multicasting with subjects best practices and guidelines caching sequence with ReplaySubject hiding subjects preserving latest state with BehaviorSubject representing asynchronous computation with AsyncSubject simple broadcasting with Subject classic misuse of subject multiple source, but one completion MultipleAssignmentDisposable, 2^nd

N

named method nested queries .NET asynchronous types, creating observables from bridging .NET asynchronous types with Rx changing synchronous method to asynchronous controlling results order converting tasks to observables creating primes observable running asynchronous code as part of pipeline using async-await in observable creation creating observables of periodic behavior creating observable timer emitting values in time intervals scheduling emission with timer .NET events composability concurrency repeatability resource handling scattered code synchronization never-ending observables, creating NewThreadScheduler, 2^nd nonoverlapping windows NSubstitute NuGet installing from overview

O

observable emissions, synchronizing changing observations execution context changing subscription/unsubscription execution context synchronizing notifications using SubscribeOn and ObserveOn together observable factory observable sequences, 2^nd, 3^rd, 4^th observable temperature cold observables ConnectableObservable, 2^nd performing automatic disconnection reconnecting cooling hot observable to allow replaying heating observables hot observables overview Observable.Create method Observable.Defer operator Observable.Empty operator Observable.Generate operator Observable.Never operator Observable.Range operator Observable.Return operator, 2^nd Observable.Throw operator Observable.Using operator ObservableBase class ObservableConnection class, 2^nd ObservableExtensions class observableFactory function observables, 2^nd aggregating basic aggregation operators finding maximum and minimum items by condition writing aggregation logic with Aggregate and Scan combining combining latest emitted values concatenating observables merging observables pairing items from observables (zipping) switching to next observable communication between observer and controlling lifetime of relationship with observers adding side effects in observable pipeline delaying subscription discarding items when another observable emits resubscribing skipping notifications stopping emitting notifications at scheduled time taking or stopping when condition is met converting enumerables to converting to enumerables converting observable to dictionary converting observable to lookup creating from events creating observables that conform to EventPattern events that aren’t following event pattern events that have no arguments events with multiple parameters creating streams of data and events with creating observables with Observable.Create deferring observable creation implementing IObservable interface ObservableBase problem with handcrafted observables filtering creating distinct sequence removing duplicate contiguous values with Where operator flattening joining into groups to flat stream published, reusing to create new observable using Rx creational operators generating observable loop primitive observables reading file. See observable temperature. ObserveOn, using with SubscribeOn ObserveOnDispatcher operator Observer pattern observers controlling lifetime of relationship with observables delaying subscription discarding items when another observable emits stopping emitting notifications at scheduled time creating creating observer instance creating observers without leaving pipeline not passing OnError and asynchronous observables observable-observer communication replacing subscription disposal with cancellation OCP (Open Close Principle) OfType operator OnComplete method OnCompleted method, 2^nd, 3^rd, 4^th OnError method, 2^nd OnError observable, not passing OnErrorResumeNext operator, 2^nd OnKeyPressed event OnMouseMove event OnNext method, 2^nd, 3^rd, 4^th, 5^th, 6^th, 7^th, 8^th, 9^th operators composable nature of using composable operators library OrderBy operator OrderByDescending operator OutOfMemoryException, 2^nd

P

Package Manager console packages, selecting pairing items from observables parameterizing concurrency PCLs (portable class libraries) period parameter periodic behavior, creating observables of creating observable timer emitting values in time intervals scheduling emission with timer PlatformServices assembly predicates preserving latest state, with BehaviorSubject publishing Publish operator, 2^nd PublishLast operator reusing published observable to create new observable simple publish pull model, 2^nd push model, 2^nd

Q

query expression syntax query operators aggregating observables basic aggregation operators finding maximum and minimum items by condition writing aggregation logic with Aggregate and Scan filtering observables creating distinct sequence removing duplicate contiguous values with Where operator flattening enumerables flattening observables mapping and query syntax

R

RanToCompletion Reactive Draw application Reactive Extensions. See Rx. Reactive Manifesto reactive programming asynchronicity and, 2^nd elasticity events Reactive Manifesto reactiveness in applications resiliency responsiveness Rx library and streams with message-driven approach Reactive Streams ReactiveTest class Received event RefCount operator, 2^nd RefCountDisposable class, 2^nd relative time Remove method removeHandler parameter, 2^nd Repeat operator, 2^nd, 3^rd repeatability, in .NET events Replay operator ReplaySubject, caching sequence with resiliency, in reactive programming resource factory resource handling in .NET events providing resources, cleaning responsiveness, in reactive programming resultSelector function, 2^nd, 3^rd Retry operator, 2^nd return statement RoutedEventArgs RoutedEventHandler Rx (Reactive Extensions) bridging .NET asynchronous types with changing synchronous method to asynchronous controlling results order converting tasks to observables creating primes observable running asynchronous code as part of pipeline using async-await in observable creation disposables library BooleanDisposable class CancellationDisposable class CompositeDisposable class ContextDisposable class Disposable.Create method Disposable.Empty property MultipleAssignmentDisposable class RefCountDisposable class ScheduledDisposable class SerialDisposable class SingleAssignmentDisposable class history of overview schedulers defining parameterizing concurrency types of synchronizing observable emissions changing observations execution context changing subscription/unsubscription execution context synchronizing notifications using SubscribeOn and ObserveOn together testing code finer control on TestScheduler TestableObservable testing concurrent code writing reactive tests with TestScheduler testing queries injecting schedulers injecting TestScheduler time-based operators adding time interval between notifications adding time-out policy adding timestamp to notification delaying notifications sampling observable in intervals throttling notifications using Rx creational operators generating observable loop primitive observables reading file Rx library rxHandler parameter RxJava port

S

Scan function, writing aggregation logic with Scan operator, 2^nd, 3^rd, 4^th scattered code, in .NET events Schedule method, 2^nd ScheduledDisposable class, 2^nd ScheduleLongRunning method SchedulePeriodic method schedulers, 2^nd defining parameterizing concurrency types of CurrentThreadScheduler EventLoopScheduler ImmediateScheduler NewThreadScheduler scheduling on SynchronizationContext TaskPoolScheduler ThreadPoolScheduler Select operator, 2^nd, 3^rd, 4^th, 5^th, 6^th SelectMany operator, 2^nd, 3^rd, 4^th, 5^th selector function, 2^nd, 3^rd, 4^th SerialDisposable class, 2^nd server-side technology Sexton, Dave Shoppy application example, 2^nd Should method side effects, immutability and SignalR library Single operator single-item observables, creating SingleAssignmentDisposable class SingleOrDefault operator Skip operator SkipUntil operator, 2^nd SkipWhile operator SLA (service-level agreement) sliding windows Sort method SortedSet source parameter StartBusy method StartWith operator, 2^nd StockMonitor class, 2^nd, 3^rd stocks, grouping by symbol StockTick class, 2^nd StockTicker class, 2^nd streams streams of data, creating with observables creating observables with Observable.Create deferring observable creation implementing IObservable interface ObservableBase problem with handcrafted observables string property StringAssertion StringBuilder StringExtensions subject Subject broadcaster classic misuse of subject multiple source, but one completion Subscribe method, 2^nd, 3^rd, 4^th, 5^th, 6^th, 7^th subscribeAsync function SubscribeConsole method SubscribeCore method SubscribeOn operator overview, 2^nd, 3^rd using with ObserveOn subscriptionDelay Sum operator Switch operator, 2^nd synchronization in .NET events performing SynchronizationContext, 2^nd, 3^rd SynchronizationContextScheduler Synchronize operator, 2^nd, 3^rd synchronous approach synchronous execution System namespace, 2^nd, 3^rd, 4^th System.Collections.Generic namespace System.Reactive package, 2^nd System.Reactive.Concurrency namespace System.Reactive.Core package, 2^nd System.Reactive.Disposables namespace System.Reactive.Interfaces package System.Reactive.Linq package System.Reactive.Observable.Aliases package, 2^nd System.Reactive.PlatformServices package System.Reactive.Providers package System.Reactive.Runtime.Remoting package System.Reactive.Subjects namespace System.Reactive.Windows.Forms package System.Reactive.Windows.Threading package System.Reactive.WindowsRuntime package System.Text.StringBuilder class System.Threading.ThreadPool class

T

Take operator TakeUntil operator overview, 2^nd, 3^rd using observables as external triggers for TakeWhile operator TAP (task-based asynchronous pattern), 2^nd Task class Task.FromAsync method Task.Run method Task.WaitAll method TaskPoolScheduler, 2^nd TaskScheduler.UnobservedTaskException event TestableObservable tester testing Rx code finer control on TestScheduler TestableObservable testing concurrent code writing reactive tests with TestScheduler Rx queries injecting schedulers injecting TestScheduler TestScheduler finer control on injecting writing reactive tests with TestScheduler.Start method TextBox.TextChanged event thread safety ThreadPoolScheduler Throttle operator, 2^nd, 3^rd, 4^th, 5^th, 6^th Ticks property ticks, finding difference between time-based operators adding time interval between notifications adding time-out policy adding timestamp to notification delaying notifications sampling observable in intervals throttling notifications time-variant variables, 2^nd TimeInterval operator, 2^nd Timeout operator, 2^nd Timer operator, 2^nd TimeSpan Timestamp operator, 2^nd, 3^rd ToArray method ToDictionary method ToEnumerable method ToList method ToLookup method ToObservable method, 2^nd, 3^rd ToString method ToTask operator ToUpper method try-catch block, 2^nd TryGetValue method tumbling windows, 2^nd Tuple.Create method Tuple<> class

U

UML (Unified Modeling Language) Using operator, 2^nd, 3^rd using statement UWP (Universal Windows Platform)

V

Value property var keyword variable delay variable throttling variables captured time-variant Visual Studio Code Volta project

W

Wait method WaitingForActivation WCF (Windows Communication Foundation) weak observer pattern WeakObserverProxy WeakReference class Where operator, 2^nd, 3^rd, 4^th, 5^th, 6^th, 7^th WhereWithLog Window operator windowBounderies observable windowing breaks observable sequence WinForms WithLatestFrom operator WPF (Windows Presentation Foundation)

X

Y

Yahoo Finance

Z

Zip operator, 2^nd, 3^rd, 4^th, 5^th zipping

..................Content has been hidden....................

You can't read the all page of ebook, please click here login for view all page.

3.145.177.39