cloudevents
/
sdk-java
mirror of https://github.com/cloudevents/sdk-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Default marshaller for ExtensionFormat 

Signed-off-by: Fabio José <fabiojose@gmail.com>
This commit is contained in:
Fabio José 2019-08-29 21:01:39 -03:00
parent e9fd715325
commit 201b5ab21b
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
api/src/main/java/io/cloudevents/extensions/ExtensionFormat.java
View File

@ -16,6 +16,7 @@
package io.cloudevents.extensions;
import java.util.Arrays;
import java.util.Collection;
import java.util.Collections;
import java.util.HashMap;
import java.util.Map;
@ -83,4 +84,18 @@ public interface ExtensionFormat {
};
}
/**
* Marshals a collection of {@link ExtensionFormat} to {@code Map<String, String>}
* @param extensions
* @return
*/
public static Map<String, String> marshal(Collection<ExtensionFormat>
extensions) {
return extensions.stream()
.map(ExtensionFormat::transport)
.flatMap(t -> t.entrySet().stream())
.collect(Collectors.toMap(Entry::getKey,
Entry::getValue));
}
}