filinvadim

// Copyright (c) 2014, Nick Patavalis ([email protected]).
// All rights reserved.
// Use of this source code is governed by a BSD-style license that can
// be found in the LICENSE file.

// Package elastic demonstrates a simple implementation of elastic
// (growable) buffers for channels. See:
// https://github.com/npat-efault/musings/wiki/Elastic-channels

const (

filinvadim

var defaultPaths = []string {
	"/.ethereum/geth.ipc", //unix
	"/Library/Ethereum/geth.ipc", //macos
	"\\\\.\\pipe\\geth.ipc", //win
}


type SocketResolver interface {
	GetSocket() string
	Connect()

filinvadim

func (c *IPCSocket) Listen() {
	buffer := bytes.Buffer{}
	for {
		reader := bufio.NewReader(c.Connect)
		line, prefix, err := reader.ReadLine()
		if err != nil {
			fmt.Printf("error: can't read form socket:", err)
			log.Fatal(err)
		}
		buffer.Write(line)

filinvadim

def decor(func):
    def wrapped(a, b):
        a = 'deco'
        b = 'rated'
        return func(a, b)
    return wrapped  # not calling yet


@decor  # init decor here

filinvadim

import asyncio

class _AsyncObject(object):
    """Inheriting this class allows you to define an async __init__.

    So you can create objects by doing something like `await MyClass(params)`
    """

    @asyncio.coroutine
    def __new__(cls, *a, **kw):

filinvadim

    def contains(self, element, list_wrap=False):
        """
        Recursively seeks for requested keyword or list of keywords
        :param data: json-type dict
        :param element: str or list
        :return: list or None
        """
        collected_elements = []

        def _recursively_seek(data):

filinvadim

    def regroup_response(self):
        """
        Groups elements of request by keys and references on keys.
        NOTE that those keys and references actually have meaning of primary and foreign key
        in the terms of SQL.
        :param data: json like request (actually dicts with lists and strings)
        :return: None
        """
        keys = {}

filinvadim

testmodules = [
    'cogapp.test_makefiles',
    'cogapp.test_whiteutils',
    'cogapp.test_cogapp',
    ]

suite = unittest.TestSuite()

for t in testmodules:
    try:

filinvadim

func multiparseText() string {
	collectedTexts := ""
	ch := make(chan string, parseThreadsNum)
	defer close(ch)
	for i := 0; i < parseThreadsNum; i++ {
		go parseText(&ch)
	}
	for {
		unreadData := len(ch)
		if unreadData == parseThreadsNum {

filinvadim

from selenium import webdriver
from selenium.webdriver.common.by import By
from selenium.webdriver.support.ui import WebDriverWait
from selenium.webdriver.support import expected_conditions as EC
import datetime
import time

while True:

# opening_browser