[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]
absolute time
Action delegate type
Add method
addHandler parameter, 2nd
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, 2nd
using in observable creation
asynchronicity
overview, 2nd
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, 2nd
backpressure
mitigating
lossless approach
lossy approach
observables of different rates
backstack
BehaviorSubject, preserving latest state with
BooleanDisposable class, 2nd
Buffer method
buffering breaks
C# programming language
advantages of
concise code
declarative programming style
first-class functions
immutability
first-class functions, 2nd
using Action
using anonymous methods
using delegates
using Func, 2nd
using lambda expressions
higher-order functions, 2nd
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, 2nd, 3rd
CancellationToken, 2nd
CancellationTokenSource, 2nd
captured variables
catch block
Catch operator, 2nd
CEP (complex event processing)
ChatClient class, 2nd
ChatRoom
Click event
client-side technology
Closed event
closures
CLR (Common Language Runtime)
code, organizing
cold observable, 2nd, 3rd
CollectionExtensions
collections
combinators
CombineLatest operator, 2nd, 3rd
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, 2nd
composition
Concat operator, 2nd, 3rd, 4th, 5th, 6th, 7th
concatenating observables
concurrency
immutability and
in .NET events
in event-processing flow
parameterizing
ConcurrentDictionary
Connect method, 2nd, 3rd, 4th
ConnectableObservable wrapper
overview
performing automatic disconnection
reconnecting
Contains operator
ContextDisposable class, 2nd
ContinueWith method
conversion function
correlation group
Count operator
CPU-based operation
Create method, 2nd, 3rd, 4th
CreateColdObservable method
CreateHotObservable method
CurrentThreadScheduler, 2nd
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, 2nd, 3rd, 4th
DeferAsync
deferred execution
Delay operator, 2nd, 3rd, 4th
DelaySubscription operator
delegates
dictionaries, converting observable to
Disposable.Create method
Disposable.Empty property, 2nd
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, 2nd, 3rd, 4th, 5th, 6th, 7th, 8th, 9th
distance variable
Distinct operator, 2nd, 3rd, 4th
DistinctUntilChanged operator, 2nd
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
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, 2nd
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, 2nd
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, 2nd, 3rd
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
fake observable
Filter operator, 2nd
FilterBursts operator, 2nd, 3rd
filtering observables
creating distinct sequence
removing duplicate contiguous values
with Where operator
filters
Finally operator, 2nd
First operator
first-class functions, 2nd
using Action
using anonymous methods
using delegates
using Func, 2nd
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, 2nd
from statements
FromEvent method, 2nd
FromEventPattern method, 2nd, 3rd
FRP (functional reactive programming)
Func delegate type
as factory
overview
functional programming
gate
GC (garbage collection)
Generate method, 2nd
GeneratePrimes method
GetAwaiter method
GetDiscounts method
GetEnumerator parameter
GetPageAsync method
GoF (Gang of Four)
Google Finance
GroupBy operator, 2nd, 3rd
grouping elements from observable
GroupJoin operator
overview, 2nd
with query syntax
groups, joining observables into
heating observables
higher-order functions, 2nd, 3rd
using Action
using anonymous methods
using delegates
using Func, 2nd
using lambda expressions
hopping windows, 2nd
hot observable, 2nd, 3rd, 4th
I/O-based operation
IAsyncAction
IAsyncOperationWithProgress
IAsyncResult object
IComparer interface
IConcurrencyProvider
IConnectableObservable interface
IDisposable interface, 2nd, 3rd, 4th, 5th, 6th
IEnumerable interface, 2nd, 3rd, 4th
Immediate Message
ImmediateScheduler
immutability
concurrency and
side effects and
imperative style
Intersect operator
Interval operator, 2nd, 3rd, 4th
IObservable interface
implementing
overview, 2nd, 3rd, 4th
IObserver interface, 2nd, 3rd, 4th
IQueryable
IScheduler interface, 2nd, 3rd, 4th
ISchedulerLongRunning
ISchedulerPeriodic
IsCompleted property
IsNullOrEmpty
IsPrimeAsync method, 2nd
IStrategy interface
ISubject interface
Join operator, 2nd, 3rd
joining observables
into groups
to flat stream
joins
keySelector function, 2nd, 3rd
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, 2nd
LogWithThread operator
LOH (Large Object Heap)
magic strings
Map operator
mapping
marble diagrams
Max operator
Merge operator, 2nd, 3rd
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, 2nd, 3rd
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, 2nd
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, 2nd
nonoverlapping windows
NSubstitute
NuGet
installing from
overview
observable emissions, synchronizing
changing observations execution context
changing subscription/unsubscription execution context
synchronizing notifications
using SubscribeOn and ObserveOn together
observable factory
observable sequences, 2nd, 3rd, 4th
observable temperature
cold observables
ConnectableObservable, 2nd
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, 2nd
Observable.Throw operator
Observable.Using operator
ObservableBase class
ObservableConnection class, 2nd
ObservableExtensions class
observableFactory function
observables, 2nd
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, 2nd, 3rd, 4th
OnError method, 2nd
OnError observable, not passing
OnErrorResumeNext operator, 2nd
OnKeyPressed event
OnMouseMove event
OnNext method, 2nd, 3rd, 4th, 5th, 6th, 7th, 8th, 9th
operators
composable nature of
using composable
operators library
OrderBy operator
OrderByDescending operator
OutOfMemoryException, 2nd
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, 2nd
PublishLast operator
reusing published observable to create new observable
simple publish
pull model, 2nd
push model, 2nd
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
RanToCompletion
Reactive Draw application
Reactive Extensions.
See Rx.
Reactive Manifesto
reactive programming
asynchronicity and, 2nd
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, 2nd
RefCountDisposable class, 2nd
relative time
Remove method
removeHandler parameter, 2nd
Repeat operator, 2nd, 3rd
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, 2nd, 3rd
Retry operator, 2nd
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
Scan function, writing aggregation logic with
Scan operator, 2nd, 3rd, 4th
scattered code, in .NET events
Schedule method, 2nd
ScheduledDisposable class, 2nd
ScheduleLongRunning method
SchedulePeriodic method
schedulers, 2nd
defining
parameterizing concurrency
types of
CurrentThreadScheduler
EventLoopScheduler
ImmediateScheduler
NewThreadScheduler
scheduling on SynchronizationContext
TaskPoolScheduler
ThreadPoolScheduler
Select operator, 2nd, 3rd, 4th, 5th, 6th
SelectMany operator, 2nd, 3rd, 4th, 5th
selector function, 2nd, 3rd, 4th
SerialDisposable class, 2nd
server-side technology
Sexton, Dave
Shoppy application example, 2nd
Should method
side effects, immutability and
SignalR library
Single operator
single-item observables, creating
SingleAssignmentDisposable class
SingleOrDefault operator
Skip operator
SkipUntil operator, 2nd
SkipWhile operator
SLA (service-level agreement)
sliding windows
Sort method
SortedSet
source parameter
StartBusy method
StartWith operator, 2nd
StockMonitor class, 2nd, 3rd
stocks, grouping by symbol
StockTick class, 2nd
StockTicker class, 2nd
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, 2nd, 3rd, 4th, 5th, 6th, 7th
subscribeAsync function
SubscribeConsole method
SubscribeCore method
SubscribeOn operator
overview, 2nd, 3rd
using with ObserveOn
subscriptionDelay
Sum operator
Switch operator, 2nd
synchronization
in .NET events
performing
SynchronizationContext, 2nd, 3rd
SynchronizationContextScheduler
Synchronize operator, 2nd, 3rd
synchronous approach
synchronous execution
System namespace, 2nd, 3rd, 4th
System.Collections.Generic namespace
System.Reactive package, 2nd
System.Reactive.Concurrency namespace
System.Reactive.Core package, 2nd
System.Reactive.Disposables namespace
System.Reactive.Interfaces package
System.Reactive.Linq package
System.Reactive.Observable.Aliases package, 2nd
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
Take operator
TakeUntil operator
overview, 2nd, 3rd
using observables as external triggers for
TakeWhile operator
TAP (task-based asynchronous pattern), 2nd
Task class
Task.FromAsync method
Task.Run method
Task.WaitAll method
TaskPoolScheduler, 2nd
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, 2nd, 3rd, 4th, 5th, 6th
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, 2nd
TimeInterval operator, 2nd
Timeout operator, 2nd
Timer operator, 2nd
TimeSpan
Timestamp operator, 2nd, 3rd
ToArray method
ToDictionary method
ToEnumerable method
ToList method
ToLookup method
ToObservable method, 2nd, 3rd
ToString method
ToTask operator
ToUpper method
try-catch block, 2nd
TryGetValue method
tumbling windows, 2nd
Tuple.Create method
Tuple<> class
UML (Unified Modeling Language)
Using operator, 2nd, 3rd
using statement
UWP (Universal Windows Platform)
Value property
var keyword
variable delay
variable throttling
variables
captured
time-variant
Visual Studio Code
Volta project
Wait method
WaitingForActivation
WCF (Windows Communication Foundation)
weak observer pattern
WeakObserverProxy
WeakReference class
Where operator, 2nd, 3rd, 4th, 5th, 6th, 7th
WhereWithLog
Window operator
windowBounderies observable
windowing
breaks
observable sequence
WinForms
WithLatestFrom operator
WPF (Windows Presentation Foundation)
3.145.7.208