Java - Streams - Revision history

Fukakai: /* Streams */

2019-10-21T17:28:40Z

Streams

@@ Line 145: / Line 145: @@
 * '''Intermediate operations:''' what should be done with the data, such as filtering or transforming it.
 * '''Terminal operation:''' what should be done with the processed data and when (or if) processing should be stopped
 ===Simple Stream Implementation===

2019-10-21T14:42:20Z

Collections

← Older revision		Revision as of 16:42, 21 October 2019
Line 1:		Line 1:
	=Collections=		=Collections=
			* Set (Ensemble): no repetitions, not sorted
			* List: can have repetitions, sorted
	==Main Methods==		==Main Methods==
	<source lang="Java">		<source lang="Java">

2019-10-18T17:55:11Z

Expanded Version of the Stream Example

← Older revision		Revision as of 19:55, 18 October 2019
Line 166:		Line 166:
	Collector<String, ?, List<String>> collector = Collectors.toList();		Collector<String, ?, List<String>> collector = Collectors.toList();
	List<String> myList = filtered.collect(collector);		List<String> myList = filtered.collect(collector);
			</source>


			===Stream Example That Contains Two Intermediate Operations===
			<source lang="java">
			List<String> filteredList =
			myItems.stream()
			.filter(item -> item.startsWith(prefix))
			.map(item -> item.toLowerCase())
			.collect(Collectors.toList());
	</source>		</source>

	=A voir=		=A voir=
	* Parallel stream		* Parallel stream

2019-10-18T17:53:51Z

Simple Stream Implementation

← Older revision		Revision as of 19:53, 18 October 2019
Line 144:		Line 144:
	* '''Terminal operation:''' what should be done with the processed data and when (or if) processing should be stopped		* '''Terminal operation:''' what should be done with the processed data and when (or if) processing should be stopped
	===Simple Stream Implementation===		===Simple Stream Implementation===

	<source lang="java">		<source lang="java">
	// Suppose that we have a collection of String instance		// Suppose that we have a collection of String instance
Line 151:		Line 152:
	.filter(item -> item.startsWith(prefix))		.filter(item -> item.startsWith(prefix))
	.collect(Collectors.toList());		.collect(Collectors.toList());
			</source>
			===Expanded Version of the Stream Example===
			<source lang="java">
			// This anonymous inner class is equivalent to the lambda: item -> (item.startsWith(prefix))
			Predicate<String> prefixSelector = new Predicate<String>() {
			public boolean test(String candidate)
			{
			return candidate.startsWith(prefix);
			}
			};
			Stream<String> dataSource = myItems.stream();
			Stream<String> filtered = dataSource.filter(prefixSelector);
			Collector<String, ?, List<String>> collector = Collectors.toList();
			List<String> myList = filtered.collect(collector);
	</source>		</source>

	=A voir=		=A voir=
	* Parallel stream		* Parallel stream

2019-10-18T17:44:22Z

Simple Stream Implementation

← Older revision		Revision as of 19:44, 18 October 2019
Line 145:		Line 145:
	===Simple Stream Implementation===		===Simple Stream Implementation===
	<source lang="java">		<source lang="java">
			// Suppose that we have a collection of String instance
			// and we want to filter the collection and create a new collection containing only the objects from the original collection that begin with some prefix
	List<String> filteredList =		List<String> filteredList =
	myItems.stream()		myItems.stream()

2019-10-18T17:43:45Z

Streams

@@ Line 135: / Line 135: @@
 =Streams=
 =A voir=
 * Parallel stream

2019-10-18T16:23:41Z

Queue

2019-10-18T16:12:56Z

Main Methods

@@ Line 100: / Line 100: @@
 Only objects that implement the Delayed interface can be added to this queue
 This class is useful when you have a group of elements that are time sensitive.
 =A voir=
 * Parallel stream

2019-10-18T16:10:36Z

DelayQueue

← Older revision		Revision as of 18:10, 18 October 2019
Line 98:		Line 98:

	===DelayQueue===		===DelayQueue===
			Only objects that implement the Delayed interface can be added to this queue
			This class is useful when you have a group of elements that are time sensitive.

	=A voir=		=A voir=
	* Parallel stream		* Parallel stream

2019-10-18T16:07:37Z

SynchronousQueue

← Older revision		Revision as of 18:07, 18 October 2019
Line 95:		Line 95:

	===SynchronousQueue===		===SynchronousQueue===
			This is a blocking queue that can’t contain any elements; instead, it blocks each request to add an element to the queue until it receives a request to retrieve an element from the queue, and vice versa.

	===DelayQueue===		===DelayQueue===

	=A voir=		=A voir=
	* Parallel stream		* Parallel stream