常連

## はじめに
retrofitを最近触り始めたのですが、
エラーハンドリングがうまくできず…
皆さんのお力を貸していただければ幸いです。

## 内容
###やりたいこと
**エラーレスポンスが返ってきた際も201などと同様に、「null」ではなく、レスポンスとして返した内容(Object)を埋め込みたい**
### 現状
　バックエンドからエラーステータス(今回は「409」)を返しており、
　Client側でもエラーステータスを正しく受けとるが、レスポンスボディに「null」が埋め込まれている(Response.java)。
　※rawResponse, body, errorBody)の中の”body”が該当
　・rawResponseはここでは気にしない
　・errorBodyは正しいものが表示される

※[retrofit2公式Github](https://github.com/square/retrofit/blob/master/retrofit/src/main/java/retrofit2/Response.java)：https://github.com/square/retrofit/blob/master/retrofit/src/main/java/retrofit2/Response.java

下記↓今回使用したInterface.java
```Interface.java
@POST("/api/family/{family_id}/menber/{member_id})
Observable<Menber> postMenber(@Header("Authorization") String token,
                                            @Path(value = "family_id") String FamilyID,
                                            @Path(value = "member_id") String MenberID,
                                            @Body Member member);
```
下記↓上記Interface使用箇所
```Activity.java
Response<Menber> resPostMenber = postMenber(fragment.sessionManager.getJwtToken(),
        family_id,
        member_id,
        requestMenber)
        .execute();
```

おそらく、retrofit2の下記仕様により、現在の事象が起きてしまっている（？）と思われるのですが
なにか対応できる方法がないか探しています。
- status >= 400の場合、一律bodyをnullで返す

もしご存知であればご教示いただけますと幸いです。

retrofit2でのエラーハンドリングについて

様々なエラーが出て、ビルド（▷Run 'app'）が出来ません。
エラー文をもとに検索をしましたが、良い解答は得られませんでした。
StackOverFlowなどの海外のサイトも当たり、試行錯誤しましたが、無意味でした。
Rebuild,Clean Project,Invalidate Caches and Restartは何回も試しました。
打つ手がない状況です。
個人的にはbuild.gradleの問題だと思っています。


何かいい方法はございませんか。

---
AndroidStudioは3.3です。

以下警告
> app: 'annotationProcessor' dependencies won't be recognized as kapt annotation processors. Please change the configuration name to 'kapt' for these artifacts: 'com.android.databinding:compiler:3.1.0'.

---
> A problem was found with the configuration of task ':app:kaptDebugKotlin'. Registering invalid inputs and outputs via TaskInputs and TaskOutputs methods has been deprecated and is scheduled to be removed in Gradle 5.0.
 Cannot write to file 'D:\Github Local\Android-1\SampleApp\app\build\intermediates\data-binding\debug\bundle-bin' 
specified for property 'dataBindingArtifactOutputDir' as it is a directory.

---
> 警告: 注釈プロセッサ'org.jetbrains.kotlin.kapt3.ProcessorWrapper'から-source '1.8'より小さいソース・バージョン'RELEASE_7'がサポートされています
e: [kapt] An exception occurred: android.databinding.tool.util.LoggedErrorException: failure, see logs for details.
Exception while handling step android.databinding.annotationprocessor.ProcessExpressions@7c86326a javax.xml.bind.UnmarshalException
 with linked exception:
[com.sun.org.apache.xerces.internal.impl.io.MalformedByteSequenceException: 1バイトのUTF-8シーケンスのバイト1が無効です。]
・・・
Caused by: com.sun.org.apache.xerces.internal.impl.io.MalformedByteSequenceException: 1バイトのUTF-8シーケンスのバイト1が無効です。

---
以下build.gradleです。

```buildgradle
apply plugin: 'com.android.application'

apply plugin: 'kotlin-android'

apply plugin: 'kotlin-android-extensions'

apply plugin: 'kotlin-kapt'

android {
    compileSdkVersion 27
    defaultConfig {
        applicationId "sampleapp.practice.com.sampleapp"
        minSdkVersion 21
        targetSdkVersion 27
        versionCode 1
        versionName "1.0"
        testInstrumentationRunner "android.support.test.runner.AndroidJUnitRunner"
    }
    buildTypes {
        release {
            minifyEnabled false
            proguardFiles getDefaultProguardFile('proguard-android.txt'), 'proguard-rules.pro'
        }
    }

    compileOptions {
        sourceCompatibility JavaVersion.VERSION_1_8
        targetCompatibility JavaVersion.VERSION_1_8
    }

    dataBinding {
        enabled = true
    }
}

dependencies {

    // model
    implementation project(':model')

    // Support Library
    def supportLibraryVersion = '27.1.0'
    implementation "com.android.support:support-v4:$supportLibraryVersion"
    implementation "com.android.support:appcompat-v7:$supportLibraryVersion"
    implementation "com.android.support:design:$supportLibraryVersion"
    implementation "com.android.support:support-vector-drawable:$supportLibraryVersion"
    implementation "com.android.support:cardview-v7:$supportLibraryVersion"
    implementation "com.android.support:customtabs:$supportLibraryVersion"
    implementation 'com.android.support.constraint:constraint-layout:1.1.0-beta6'

    // glide
    implementation 'com.github.bumptech.glide:glide:3.7.0'

    // kotlin
    implementation "org.jetbrains.kotlin:kotlin-stdlib-jdk8:$kotlin_version"

    // retrofit
    def retrofitVersion = '2.3.0'
    implementation "com.squareup.retrofit2:retrofit:$retrofitVersion"
    implementation "com.squareup.retrofit2:converter-moshi:$retrofitVersion"
    implementation "com.squareup.retrofit2:adapter-rxjava2:$retrofitVersion"

    // Kotshi
    def kotshiVersion = '1.0.2'
    implementation "se.ansman.kotshi:api:$kotshiVersion"
    kapt "se.ansman.kotshi:compiler:$kotshiVersion"

    // RxJava
    implementation "io.reactivex.rxjava2:rxjava:2.1.11"
    implementation 'io.reactivex.rxjava2:rxandroid:2.0.2'
    implementation 'io.reactivex.rxjava2:rxkotlin:2.2.0'

    // Dagger
    def daggerVersion = '2.15'
    implementation "com.google.dagger:dagger:$daggerVersion"
    implementation "com.google.dagger:dagger-android:$daggerVersion"
    implementation "com.google.dagger:dagger-android-support:$daggerVersion"
    kapt "com.google.dagger:dagger-compiler:$daggerVersion"
    kapt "com.google.dagger:dagger-android-processor:$daggerVersion"

    // MultiDex
    implementation 'com.android.support:multidex:1.0.3'

    // Android Architecture Components
    implementation 'android.arch.lifecycle:runtime:1.1.1'
    implementation 'android.arch.lifecycle:extensions:1.1.1'
    implementation 'android.arch.lifecycle:reactivestreams:1.1.1'
    implementation 'android.arch.persistence.room:runtime:1.0.0'
    implementation "android.arch.persistence.room:rxjava2:1.0.0"
    implementation "android.arch.lifecycle:common-java8:1.0.0"
    kapt 'android.arch.persistence.room:compiler:1.0.0'
    kapt 'com.android.databinding:compiler:3.1.0'

    // OkHttp
    implementation 'com.squareup.okhttp3:logging-interceptor:3.10.0'

    // Test
    testImplementation 'junit:junit:4.12'
    testImplementation "com.nhaarman:mockito-kotlin:1.5.0"

    testImplementation "org.robolectric:robolectric:3.5.1"

    androidTestImplementation 'com.android.support.test:runner:1.0.1'
    androidTestImplementation 'com.android.support.test.espresso:espresso-core:3.0.1'
}

```
```buildgradle
buildscript {
    ext.kotlin_version = '1.2.30'
    repositories {
        google()
        jcenter()
    }
    dependencies {
        classpath 'com.android.tools.build:gradle:3.1.0'
        classpath "org.jetbrains.kotlin:kotlin-gradle-plugin:$kotlin_version"

        // NOTE: Do not place your application dependencies here; they belong
        // in the individual module build.gradle files
    }
}

allprojects {
    repositories {
        google()
        jcenter()
    }
}

task clean(type: Delete) {
    delete rootProject.buildDir
}

```

kotlinの環境構築でbuildが出来ない

下記のページの
https://api.hatchways.io/assessment/students
情報を表示させたいのですが
うまく表示できません。

```React
import React, {useState, useEffect} from 'react';
import axios from 'axios';


const Top = () => {
  const [post, setPosts] = useState([])

  console.log(post);
  console.log(post.students);

  useEffect(() => {
    axios.get('https://api.hatchways.io/assessment/students')
    .then(result => {
        setPosts(result.data)
    })
  }, []);

  return (
    <div>
      {post.students[0].city}
    </div>
  );
}

export default Top;
```

![イメージ説明](https://ddjkaamml8q8x.cloudfront.net/questions/2022-06-01/580a9f98-057e-4cce-9475-4b993d1e6875.png)
```ここに言語を入力
  console.log(post);
  console.log(post.students);
```
の部分は写真の通りコンソールではAPIの内容を表示できているのですが
 return内で表示されません。

最終的な目標はMapなどでPost変数の一覧を表示させたいと思っていますが
一つの要素を表示させるところで躓いています。。


ReactにてAPIのデータをうまく表示できません。

```kotlin
override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
  super.onViewCreated(view, savedInstanceState)

// ViewModelFolder.selectFolder はMutableLiveData<String>
  ViewModelFolder.selectFolder.observe(viewLifecycleOwner, Observer { name ->
      name?.let {
        taskViewModel.getTasksByFolder(it, false)
          .observe(viewLifecycleOwner, Observer { tasks ->
            tasks?.let { taskAdapter.setTasks(it) }
          })
      }
    })
}
```
TabLayoutのためにFragmentを使ってます。
Folder名が変更またはTaskが変更した場合に`taskViewModel.getTasksByFolder `を呼びたいです。
上記のようにObserveの中にObserveを書くと中のObserveが複数回呼ばれてしまいます。
どうすれば正常に動かせますか？

android: Observe

[RxAndroidBleでスキャンする
](http://harumi.sakura.ne.jp/wordpress/2019/02/20/rxandroidble%e3%81%a7%e3%82%ad%e3%83%a3%e3%83%b3%e3%81%99%e3%82%8b/?preview_id=970&preview_nonce=12a6bf567c&preview=true&_thumbnail_id=983)の記事を参考にスキャンを行い身の回りにあるデバイスの名前を出力することができました。

次にconnectを行いたいと思ったのですがこれがどう実装すれば良いのかわかりません。
READMEには以下の様にconnectすると記述されていました。
```Kotlin
String macAddress = "AA:BB:CC:DD:EE:FF";
RxBleDevice device = rxBleClient.getBleDevice(macAddress);

Disposable disposable = device.establishConnection(false) // <-- autoConnect flag
    .subscribe(
        rxBleConnection -> {
            // All GATT operations are done through the rxBleConnection.
        },
        throwable -> {
            // Handle an error here.
        }
    );

// When done... dispose and forget about connection teardown :)
disposable.dispose();
```

現在コードは以下の様になっています。
establishConnectionでConnectをするとREADMEにあったので以下のように試してみたのですがConnectできません。何か別途必要なものがあるのでしょうか?
```Kotlin
val scanSubscription = rxBleClient.scanBleDevices(
            ScanSettings.Builder().build()
        ).filter {
            it.scanRecord.deviceName != null

        }.subscribe({scanResult ->
            Log.i("ScanDevice:",scanResult.scanRecord.deviceName)
            val cubeAdress = scanResult.bleDevice.macAddress
            //ここでconnectしたい
            scanResult.bleDevice.establishConnection(false)
            
        },{throwable ->
            Log.i("error","$throwable")
        })
```

RxAndroidBleでConnectを行いたい

### 複数 API を並列で通信させて、結果が全て揃うまで待機して次の処理に進む方法が知りたいです

表題の件を実現するために Android で RxJava を初めて使って処理を書いていますが、並列で通信に行くものの結果を待つことができず、解決策を探しています。

RxJava に詳しい方がいらっしゃいましたら、解決方法を教えていただけませんでしょうか。

よろしくお願いします。

### ソースコード

```Java
class GetAllData() {
	final GetData g1 = new GetData();
	final GetData g2 = new GetData();

	Observabole<Boolean> task1 = Observable.create(new ObservableOnSubscribe() {
		@Override
		public void subscribe(ObservableEmitter emitter) throws Exception {
			g1.async(emitter);
		}
	}

	Observabole<Boolean> task2 = Observable.create(new ObservableOnSubscribe() {
		@Override
		public void subscribe(ObservableEmitter emitter) throws Exception {
			g2.async(emitter);
		}
	}

	Observable.zip(task1, task2, new BiFunction<Boolean, Boolean, Booelan>() {
		@Override
		public Boolean apply(Boolan result1, Boolean result2) throws Exception {
			log.d("TEST", "complete:"); ← 全ての処理が終わったら呼ばれると思っているが呼ばれない状態です
			return true;
		}
	}).subscribe();
}

class GetData {
	public void async(ObservableEmitter emitter) {
		this.emitter = emmiter;
		apiCall();    // 通信してデータを取得したら response() が呼ばれる
	}

	@Override
	public response(int code, String data) {
		if (data == null) {
			emitter.onError(new Throwable("error"));    // 取得失敗
		} else {
			emitter.onNext(true);    // データ取得成功
		}
	}

}
```

非同期で複数の API を並列で通信した結果を全て待機してから次の処理に進む方法が知りたいです

### 前提

ここに質問の内容を詳しく書いてください。
（例）
TypeScriptで●●なシステムを作っています。
■■な機能を実装中に以下のエラーメッセージが発生しました。

### 実現したいこと

ここに実現したいことを箇条書きで書いてください。
- [ ] ▲▲機能を動作するようにする

### 発生している問題・エラーメッセージ

```
エラーメッセージ
```

### 該当のソースコード

```ここに言語名を入力
ソースコード
```

### 試したこと

ここに問題に対して試したことを記載してください。

### 補足情報（FW/ツールのバージョンなど）

ここにより詳細な情報を記載してください。


aaaaaaaaaaaaaa

２つのLiveDataを監視したいです。

```Kotlin
val item = MutableLiveData<Item>().apply { value = taskAdapter.getItem(1) }
val task = MutableLiveData<Task>().apply { value = taskAdapter.getTask() }
val fetchTasks = MediatorLiveData<Unit>()

val taskObserver = Observer<Any> {
      val name = item.value as String
      fetchTasks.value = taskViewModel.getTasksByItemname(name, false).observe(viewLifecycleOwner, Observer { tasks ->
        tasks?.let { taskAdapter.setTasks(it) }
      })
}
fetchTasks.addSource(folderName, taskObserver)
fetchTasks.addSource(tasks, taskObserver)
```
このようにアイテムかタスクに変更があればタスクのリストをRoomDBから持ってきたいのですがうまくいきません。
どうすればいいですか？