NikitaKozlov

{
  "contractVersion": 1,
  "layout": {
    "type": "vertical_list",
    "content": [
      {
                  "type": "top_sights",
                  "title": "Top sights near Eiffel Tower",
                  "content": [
                    {

NikitaKozlov

{
  "contractVersion": 1,
  "layout": {
    "type": "vertical_list",
    "content": [
      {
        "type": "location_banner",
        "title": "Paris",
        "button_text": "See all 731 tickets & tours",
        "image_url": "https://cdn.getyourguide.com/img/tour/5f367de9d9c98.jpeg/145.jpg",

NikitaKozlov

class ItemRepository(val backendApi: BackendApi, val cache: ItemCache) {

    fun getOrderedItemIds(pageNumber: Int) = backendApi.getItemIds(pageNumber)

    fun getItemsByIds(itemIds: List<ItemId>): List<Item>  {
        val cachedItems = getCachedItems(itemIds)
        val notCachedItemIds = getItemIdsNotRepresentedInCache(itemIds)
        val newlyRequestedItems = requestItemsById(notCachedItemIds)
        return merge(itemIds, cachedItems, newlyRequestedItems)
    }

NikitaKozlov

inputStream.groupBy(Event::getItemId)
    .subscribe(substream -> 
        substream.onBackpressureLatest()
               .subscribe(new Subscriber<Event>() {
                   public void onNext(Event event) {
                      if (shouldSkipEvent(event)) {
                          outputStream.onNext(Response.createSkippedResponse());
                          request(1);
                      } else {
                          saveLastLaunchedEvent(event);

NikitaKozlov

import sys, os, shutil

def generateClass(directory, classNumber, methodsPerClass, mainPackage):
    className = "Foo" + str(classNumber)
    filePath = os.path.join(directory, className + ".java")
    with open(filePath,"w+") as f:
        f.write("package " + mainPackage + "." + directory + ";\n")
        f.write("public class " + className + " {\n")
        for i in xrange(0, methodsPerClass):
            f.write("public void foo" + str(i) + "(){\n")