public final class ChronicleStream<K,V> extends ChronicleReaderStream<K,V>
MapStream.MutableSignal<K,V>, MapStream.Operation, MapStream.Signal<K,V>
chronicle, CONSUMER_UPDATER, consumers, keyCodec, localCache, name, valueCodec
Constructor and Description |
---|
ChronicleStream(String name) |
ChronicleStream(String name,
int messageSizeHint) |
ChronicleStream(String name,
int messageSizeHint,
net.openhft.chronicle.Chronicle chronicle) |
ChronicleStream(String name,
int messageSizeHint,
net.openhft.chronicle.Chronicle chronicle,
Codec<Buffer,K,K> keyCodec,
Codec<Buffer,V,V> valueCodec) |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
void |
deleteOnExit() |
V |
put(K key,
V value) |
void |
putAll(Map<? extends K,? extends V> m) |
V |
remove(Object key) |
protected boolean |
sameOrNotEqual(V previous,
V value) |
int |
size() |
protected void |
writePut(K key,
V previous,
V value) |
protected void |
writePutAll(Map<? extends K,? extends V> m) |
protected void |
writeRemove(Object key) |
chronicle, containsKey, containsValue, entrySet, equals, get, hashCode, isEmpty, keyCodec, keySet, localCache, subscribe, toString, valueCodec, values
adaptiveConsume, adaptiveConsumeOn, after, batchConsume, batchConsumeOn, broadcast, broadcastOn, broadcastTo, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, cache, cancelSubscription, capacity, cast, combine, concatMap, concatWith, consume, consume, consume, consume, consume, consumeLater, consumeOn, consumeOn, consumeOn, count, count, decode, defaultIfEmpty, dematerialize, dispatchOn, dispatchOn, dispatchOn, distinct, distinct, distinctUntilChanged, distinctUntilChanged, downstreamSubscription, elapsed, elementAt, elementAtOrDefault, encode, env, exists, fanIn, filter, filter, finallyDo, flatMap, getCapacity, getDispatcher, getEnvironment, getTimer, groupBy, ignoreError, ignoreError, isReactivePull, join, joinWith, keepAlive, last, lift, log, log, map, materialize, merge, mergeWith, nest, next, observe, observeCancel, observeComplete, observeError, observeStart, observeSubscribe, onErrorResumeNext, onErrorResumeNext, onErrorReturn, onErrorReturn, onOverflowBuffer, onOverflowBuffer, onOverflowDrop, partition, partition, process, recover, reduce, reduce, repeat, repeat, repeatWhen, requestWhen, retry, retry, retry, retry, retryWhen, sample, sample, sample, sample, sample, sample, sampleFirst, sampleFirst, sampleFirst, sampleFirst, sampleFirst, sampleFirst, scan, scan, skip, skip, skip, skipWhile, skipWhile, sort, sort, sort, sort, split, split, startWith, startWith, startWith, subscribe, subscribeOn, subscribeOn, subscribeOn, switchMap, take, take, take, takeWhile, tap, throttle, throttle, timeout, timeout, timeout, timeout, timestamp, toBlockingQueue, toBlockingQueue, toList, toList, unbounded, when, window, window, window, window, window, window, window, window, window, window, window, zip, zipWith, zipWith
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
compute, computeIfAbsent, computeIfPresent, forEach, getOrDefault, merge, putIfAbsent, remove, replace, replace, replaceAll
public ChronicleStream(String name) throws IOException
IOException
public ChronicleStream(String name, int messageSizeHint) throws IOException
IOException
public ChronicleStream(String name, int messageSizeHint, net.openhft.chronicle.Chronicle chronicle)
Copyright © 2016. All rights reserved.