Gibt es eine Umkehrung von BiConsumer für die Zuordnung zu mehreren Werten wie Tupel

Question

Ich habe versucht, einen Strom von Zeichenfolgen auf den Hash dieser Zeichenfolgen abzubilden, während die Zeichenfolgen in der Ausgabe beibehalten werden. Am Ende konvertierte ich den Hash in eine Zeichenkette, so dass ich entweder eine String[] zuordnen oder sie sogar als eine Zeichenkette zusammenfügen konnte. Ich hätte vorgezogen in einem Lambda-Ausgang hätte sowohl eine String als auch eine byte[] Vermeidung einer Umwandlung sein können. Ohne ein spezifisches Wertobjekt zu definieren, das nur diese beiden enthält, gibt es eine Art reziproker BiConsumer, d. H. Einen BiProducer?

public static final ArrayList<String> inputs; // ... initialized elsewhere 
... 
inputs.parallelStream().map(s -> { 
    try { 
    String h = String.format("%032x", 
     new BigIntger(1, MessageDigest.getInstance("MD5") 
         .digest(s.getBytes(StandardCharsets.UTF_8)))); 
    String[] r = {s, h}; 
    return r; 
    } catch (NoSuchAlgorithmException e) { 
    throw new RuntimeException(e); 
    } 
}).foreach(tuple -> {String input = tuple[0], hash = tuple[1]; ...}); 

Sie sehen, wenn in foreach ich eine byte[] des Hash wollte ich es mir gewünscht hätte zu passieren, was ich schon in der map hatte, sonst würde ich zu und aus einem String werden Umwandlung lediglich in der Lage sein übergeben Sie es bequem. Offensichtlich, wenn ich eine Klasse machen würde, nur um diese beiden Typen zu halten, wäre das die mühsame Lösung; Gibt es kein bereits bestehendes Angebot für Mapping-Schritte, die auf mehrere Werte stromabwärts übertragen werden?

Answer 1

Verwirrung über die BiConsumer beiseite, danke für den Vorschlag StreamEx in den Kommentaren. Es sieht aus wie es eine sehr schöne Art und Weise hat dies zu schreiben, wie:

StreamEx.of(inputs).toMap(Functions.identity(), 
          s -> { 
          try { 
           return new BigIntger(1, MessageDigest.getInstance("MD5") 
             .digest(s.getBytes(StandardCharsets.UTF_8)))); 
          } catch (NoSuchAlgorithmException e) { 
           throw new RuntimeException(e); 
          }).etc...; 

Es stellt sich heraus, für diesen Fall, da ich weiß, dass die Eingabe eindeutig ist, kann ich dies mit den verfügbaren grouping collector ähnlich tun:

inputs.stream().collect(
    toConcurrentMap(Functions.identity(), 
        s -> { 
         try { 
         return new BigIntger(1, MessageDigest.getInstance("MD5") 
            .digest(s.getBytes(StandardCharsets.UTF_8)))); 
         } catch (NoSuchAlgorithmException e) { 
         throw new RuntimeException(e); 
         }).etc...;