trishagee

package ch15;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.InetSocketAddress;
import java.nio.channels.Channels;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.ArrayList;

trishagee

package ch15;

import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

trishagee

package ch15;

import javax.swing.*;
import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;

trishagee

package ch15;

import javax.swing.*;
import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.CharBuffer;

trishagee

List.of(manager1, manager2).stream()
    .flatMap(m ->
       Stream.concat(m.getEmployeeList().stream(), Stream.of(m)))
    .distinct()
    .mapToInt(Employee::getYearlySalary)
    .sum();

trishagee

@RestController
class RestController(val priceService: PriceService) {
    fun prices(@PathVariable symbol: String): Flux<StockPrice> {

    }
}

trishagee

package com.mechanitis.demo.stockservice

import org.springframework.boot.autoconfigure.SpringBootApplication
import org.springframework.boot.runApplication

@SpringBootApplication
class StockServiceApplication

fun main(args: Array<String>) {
    runApplication<StockServiceApplication>(*args)

trishagee

    public static class CityAndPhone {

        private String city;
        private String phone;

        public CityAndPhone(String city, String phone) {
            this.city = city;
            this.phone = phone;
        }

trishagee

static int[][] computeLevenshtein(List<String> wordList, boolean parallel) {
    final int LIST_SIZE = wordList.size();
    int[][] distances = new int[LIST_SIZE][LIST_SIZE];
    IntStream stream = IntStream.range(0, LIST_SIZE);

    if (parallel) {
        stream = stream.parallel(); // Convert the stream to a parallel one
    }

    stream.forEach(i -> {

trishagee

static int[][] computeLevenshtein(List<String> wordList, boolean parallel) {
    final int LIST_SIZE = wordList.size();
    int[][] distances = new int[LIST_SIZE][LIST_SIZE];

    Supplier<Stream<String>> streamSupplier = () -> wordList.stream();
    Stream<String> stream = streamSupplier.get();

    if (true == parallel) {
        stream = stream.parallel();
    }