akka/akka-core

Generalize Split strategies

Aberta

#19.253 aberto em 21 de dez. de 2015

 (3 comentários) (0 reação) (0 responsável)Scala (3.547 forks)batch import
1 - triagedhelp wantedt:stream

Métricas do repositório

Stars
 (13.277 estrelas)
Métricas de merge de PR
 (Mesclagem média 8d 19h) (10 fundiu PRs em 30d)

Description

Split currently only supports one of SplitBefore and SplitAfter where all elements ultimately land in one of the to substreams.

A combination of both could emit more than two substreams where elements outside of these start and end markers are dropped.

This could render StreamUtils.sliceBytesTransformer redundant which is currently used in RangeDirectives.

Guia do colaborador