samuelteixeiras

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

samuelteixeiras

var socket = io();

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

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

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

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

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

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

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 final String OSWALD_ALONE = "Oswald acted alone";
private static final String FAVORITE_MOVIE = "matrix";
private static final String MOVIE_RATE_VALUE = "5";
private static final String MOVIE_RATE = "Move rating is: " + MOVIE_RATE_VALUE;

@Test
public void itTestFilmRating() {
    InputStream in = new ByteArrayInputStream(MOVIE_RATE_VALUE.getBytes());
    System.setIn(in);