samuelteixeiras

package weekOne;

import org.junit.After;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.InputStream;

samuelteixeiras

private static List<Integer> getIntegerList(List<Integer> numbers) throws InterruptedException {
        return numbers
                .stream()
                .map(
                        number ->
                                CompletableFuture.supplyAsync(
                                        () -> getNumberCalculation(number),
                                        executor
                                )
                )

samuelteixeiras

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;

samuelteixeiras

private static List<Integer> getIntegerList2(List<Integer> numbers) {
        return numbers
                .stream()
                .map(
                        number ->
                                CompletableFuture.supplyAsync(
                                        () -> getNumberCalculation(number),
                                        executor
                                )
                )

samuelteixeiras

from twitter_auth import API_KEY, API_SECRET
import tweepy as tp
from datetime import datetime
import csv
import time

SOURCE_KEYWORDS = 'ireland alcohol' + ' -filter:retweets'

auth = tp.OAuth2AppHandler(
    API_KEY, API_SECRET

samuelteixeiras

const express = require('express')
const app = express()

// set the public folder, place for static files. 
app.use(express.static(__dirname + '/public'));

samuelteixeiras

app.post('/successfulNotification', function (req, res) {

  res = res.status(200);
  res.send(req.body);

  try {
    var htmlHeader = prettyHtml(req.headers, req.body.dimensions);
    var htmlBody = prettyHtml(JSON.parse(req.body), req.body.dimensions);
    io.emit('chat message', '<div class="msg-header-success">Successful Notification received at:' 
            + formatDate(new Date(), "dddd h:mm:sstt d MMM yyyy") +'</div>');

samuelteixeiras

var socket = io();

$('form').submit(function(){
  socket.emit('chat message', "<div class='msg-ping'>Ping:" + $('#m').val() + "</div>");
  $('#m').val('');
  return false;
});

samuelteixeiras

 socket.on('chat message', function(msg){
          $('#messages').append(msg);
          window.scrollTo(0, document.body.scrollHeight);
});

samuelteixeiras

app.post('/failureNotification', function (req, res) {

  res = res.status(200);
  res.send(req.body);

  try {
    var htmlHeader = prettyHtml(req.headers, req.body.dimensions);
    var htmlBody = prettyHtml(JSON.parse(req.body), req.body.dimensions);
    io.emit('chat message', '<div class="msg-header-failure">Failure Notification received at:'+ formatDate(new Date(), "dddd h:mm:sstt d MMM yyyy") +'</div>');
    io.emit('chat message', '<div class="header-failure">Header</div>');