let persister flow nullables to understand absense. (#30)
This is possibly temporary until we get a StoreResponse but may still keep it as we wouldn't want to force everything to support StoreResponse
This commit is contained in:
parent
d1ac07d8d0
commit
92022be61a
1 changed files with 1 additions and 1 deletions
|
@ -51,7 +51,7 @@ fun <Key, Output> PipelineStore<Key, Output>.withCache(
|
||||||
|
|
||||||
@FlowPreview
|
@FlowPreview
|
||||||
fun <Key, OldOutput, NewOutput> PipelineStore<Key, OldOutput>.withPersister(
|
fun <Key, OldOutput, NewOutput> PipelineStore<Key, OldOutput>.withPersister(
|
||||||
reader: (Key) -> Flow<NewOutput>,
|
reader: (Key) -> Flow<NewOutput?>,
|
||||||
writer: suspend (Key, OldOutput) -> Unit,
|
writer: suspend (Key, OldOutput) -> Unit,
|
||||||
delete: (suspend (Key) -> Unit)? = null
|
delete: (suspend (Key) -> Unit)? = null
|
||||||
): PipelineStore<Key, NewOutput> {
|
): PipelineStore<Key, NewOutput> {
|
||||||
|
|
Loading…
Reference in a new issue